Can the Event::Init be received during application work (not start up)? How to be sure store doesn't have an outdated data?

[artsiomkaltovich]

As far as I understand you can receive Event::Init several times: not only on the application startup but on every watching restart, e.g. due to some connection issues.

I have a store which keep the watching objects. Does it means I should recreate it on every Init event? I thought about purging all presented onject, but neither store, not writer doesn't have such method.

Will old object be presented in the store after init? Or if I apply it to the writer it will clear the store? As I can understand via source code it is the case. Am I right? I fail to find this case in documentation.

Thank you in advance.

[nightkr]

not only on the application startup but on every watching restart, e.g. due to some connection issues.

If you lose your connection then watcher will first try to restore that connection from where it left off.

If that fails because we're too far behind (Kubernetes only allows about 5 minutes' worth of replay) then Init will be reissued.

I have a store which keep the watching objects. Does it means I should recreate it on every Init event? I thought about purging all presented onject, but neither store, not writer doesn't have such method.

If you maintain your store manually, then yes, you need to purge it whenever you receive an Init.

If you use our reflector then this will automatically be handled for you, and you don't need to do anything special yourself.

[artsiomkaltovich]

Thank you for your answer. Could you clarify about "maintain your store manually"?

From my understanding of the source code, Init will delete old data—is that correct? I apply every event to the writer, so I assume that should handle it at least in my case, shoundn't it?

[nightkr]

From my understanding of the source code, Init will delete old data—is that correct? I apply every event to the writer, so I assume that should handle it at least in my case, shoundn't it?

Yes.

Could you clarify about "maintain your store manually"?

For example, if you build up your own HashMap<ObjectRef<K>, K> (or do something else entirely with the objects) instead of using kube-rs' Store/reflector system.

[artsiomkaltovich]

Thank you for clarification.