client

type ChangeRequest interface {
	// Update appends updates for given items to the request.
	Update(items ...proto.Message) ChangeRequest

	// Delete appends deletes for given items to the request.
	Delete(items ...proto.Message) ChangeRequest

	// Send sends the request.
	Send(ctx context.Context) error
}

type ConfigClient = GenericClient

type ConfigItem = generic.ConfigItem

type Filter struct {
	Ids    []*generic.Item_ID
	Labels map[string]string
}

type GenericClient interface {
	// KnownModels retrieves list of known modules.
	KnownModels(class string) ([]*ModelInfo, error)

	// ChangeRequest returns transaction for changing config.
	ChangeRequest() ChangeRequest

	// ResyncConfig overwrites existing config.
	ResyncConfig(items ...proto.Message) error

	// GetConfig retrieves current config into dsts.
	// TODO: return as list of config items
	GetConfig(dsts ...interface{}) error

	// GetFilteredConfig retrieves current config into dsts according to the provided filter.
	GetFilteredConfig(filter Filter, dsts ...interface{}) error

	// GetItems returns list of all current ConfigItems.
	GetItems(ctx context.Context) ([]*ConfigItem, error)

	UpdateItems(ctx context.Context, items []UpdateItem, resync bool) ([]*UpdateResult, error)

	DeleteItems(ctx context.Context, items []UpdateItem) ([]*UpdateResult, error)

	// DumpState dumps actual running state.
	DumpState() ([]*StateItem, error)
}

type ModelInfo = models.ModelInfo

type ProtoTxnFactory interface {
	NewTxn(resync bool) keyval.ProtoTxn
}

type StateItem = generic.StateItem

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

type UpdateItem struct {
	Message proto.Message
	Labels  map[string]string
}

type UpdateResult struct {
	Key    string
	Status *generic.ItemStatus
}