states

type DeleteOption struct {
	Concurrency string `json:"concurency"` //concurrency
	Consistency string `json:"consistency` //eventual or strong
}

type DeleteRequest struct {
	ID       string                 `json:"id"`
	ETag     *string                `json:"etag,omitempty"`
	Metadata map[string]interface{} `json:"metadata"`
	Options  DeleteOption           `json:"options,omitempty"`
}

type GetOption struct {
	Consistency string `json:"consistency"` //eventual or strong
}

type GetRequest struct {
	ID       string                 `json:"id"`
	Metadata map[string]interface{} `json:"metadata"`
	Options  GetOption              `json:"options,omitempty"`
}

type IStateProvider interface {
	Init(config providers.IProviderConfig) error
	Upsert(context.Context, UpsertRequest) (string, error)
	Delete(context.Context, DeleteRequest) error
	Get(context.Context, GetRequest) (StateEntry, error)
	List(context.Context, ListRequest) ([]StateEntry, string, error)
	SetContext(context *contexts.ManagerContext)
}

type ListRequest struct {
	FilterType  string                 `json:"filterType"`
	FilterValue string                 `json:"filterValue"`
	Metadata    map[string]interface{} `json:"metadata"`
}

type StateEntry struct {
	ID   string      `json:"id"`
	Body interface{} `json:"body"`
	ETag string      `json:"etag,omitempty"`
}

type UpsertOption struct {
	Concurrency     string `json:"concurrency,omitempty"` //first-write, last-write
	Consistency     string `json:"consistency"`           //eventual, strong
	UpdateStateOnly bool   `json:"updateStateOnly,omitempty"`
}

type UpsertRequest struct {
	Value    StateEntry             `json:"value"`
	ETag     *string                `json:"etag,omitempty"`
	Metadata map[string]interface{} `json:"metadata"`
	Options  UpsertOption           `json:"options,omitempty"`
}