Documentation
¶
Index ¶
- type Store
- func (s *Store) Create(item *Value) storage.PutOp[*Value]
- func (s *Store) DeleteByKey(instanceID, executionID string) storage.DeleteOp
- func (s *Store) ExistsByKey(instanceID, executionID string) storage.ExistsOp
- func (s *Store) GetAll() storage.GetMultipleOp[*Value]
- func (s *Store) GetByInstanceID(instanceID string) storage.GetMultipleOp[*Value]
- func (s *Store) GetByKey(instanceID, executionID string) storage.GetOp[*Value]
- func (s *Store) InstanceIDPrefix(instanceID string) string
- func (s *Store) InstancesPrefix() string
- func (s *Store) Key(instanceID, executionID string) string
- func (s *Store) Update(item *Value) storage.PutOp[*Value]
- type Value
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) DeleteByKey ¶
func (*Store) ExistsByKey ¶
func (*Store) GetByInstanceID ¶
func (s *Store) GetByInstanceID(instanceID string) storage.GetMultipleOp[*Value]
func (*Store) InstanceIDPrefix ¶
func (*Store) InstancesPrefix ¶
type Value ¶
type Value struct {
storage.StoredValue
WorkflowInstance *workflow.Instance `json:"workflow_instance"`
CreatedAt time.Time `json:"created_at"`
FinishedAt *time.Time `json:"finished_at,omitempty"`
Queue core.Queue `json:"queue"`
Metadata *metadata.WorkflowMetadata `json:"metadata"`
State core.WorkflowInstanceState `json:"state"`
}
Click to show internal directories.
Click to hide internal directories.