configuration

type GetRequest struct {
	Keys     []string          `json:"keys"`
	Metadata map[string]string `json:"metadata"`
}

type GetResponse struct {
	Items []*Item `json:"items"`
}

type Item struct {
	Key      string            `json:"key"`
	Value    string            `json:"value,omitempty"`
	Version  string            `json:"version,omitempty"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type Metadata struct {
	Properties map[string]string `json:"properties"`
}

type Store interface {
	// Init configuration store.
	Init(metadata Metadata) error

	// Get configuration.
	Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

	// Subscribe configuration by update event.
	Subscribe(ctx context.Context, req *SubscribeRequest, handler UpdateHandler) (string, error)

	// Unsubscribe configuration with keys
	Unsubscribe(ctx context.Context, req *UnsubscribeRequest) error
}

type SubscribeRequest struct {
	Keys     []string          `json:"keys"`
	Metadata map[string]string `json:"metadata"`
}

type UnsubscribeRequest struct {
	ID string `json:"id"`
}

type UpdateEvent struct {
	ID    string  `json:"id"`
	Items []*Item `json:"items"`
}

type UpdateHandler func(ctx context.Context, e *UpdateEvent) error