configsync

type AESGCMCrypto struct {
	// contains filtered or unexported fields
}

type ConfigFetcher interface {
	Fetch(ctx context.Context, etag string) (raw []byte, version string, notModified bool, err error)
}

type ConfigStore[T any] interface {
	Load() (*Versioned[T], bool)
	Swap(v *Versioned[T])
	Version() string
}

type Crypto interface {
	Encrypt(plaintext []byte) ([]byte, error)
	Decrypt(ciphertext []byte) ([]byte, error)
}

type LKGStore[T any] struct {
	// contains filtered or unexported fields
}

type MemoryStore[T any] struct {
	// contains filtered or unexported fields
}

type SnapshotCodec[T any] interface {
	Encode(snapshot T) (raw []byte, err error)
	Decode(raw []byte) (T, error)
	Version(raw []byte) string
}

type StreamTransport interface {
	Watch(ctx context.Context) (version string, err error)
	Ack(ctx context.Context, appliedVersion string) error
}

type Versioned[T any] struct {
	Version  string
	Snapshot T
	Raw      []byte
}

type Worker[T any] struct {
	// contains filtered or unexported fields
}

type WorkerConfig struct {
	PollInterval time.Duration
	MinBackoff   time.Duration
	MaxBackoff   time.Duration
}

type WorkerOption[T any] func(*Worker[T])