Documentation
¶
Index ¶
- type Store
- func (s *Store) AllQueuesPrefix() string
- func (s *Store) Create(item *Value) storage.PutOp[*Value]
- func (s *Store) DeleteByKey(queue, instanceID, executionID string) storage.DeleteOp
- func (s *Store) GetAll() storage.GetMultipleOp[*Value]
- func (s *Store) GetByInstanceID(queue, instanceID string) storage.GetMultipleOp[*Value]
- func (s *Store) GetByKey(queue, instanceID, executionID string) storage.GetOp[*Value]
- func (s *Store) GetByQueue(queue string) storage.GetMultipleOp[*Value]
- func (s *Store) InstanceIDPrefix(queue, instanceID string) string
- func (s *Store) Key(queue, instanceID, executionID string) string
- func (s *Store) Put(item *Value) storage.PutOp[*Value]
- func (s *Store) QueuePrefix(queue 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) AllQueuesPrefix ¶
func (*Store) DeleteByKey ¶
func (*Store) GetByInstanceID ¶
func (s *Store) GetByInstanceID(queue, instanceID string) storage.GetMultipleOp[*Value]
func (*Store) GetByQueue ¶
func (s *Store) GetByQueue(queue string) storage.GetMultipleOp[*Value]
func (*Store) InstanceIDPrefix ¶
func (*Store) QueuePrefix ¶
type Value ¶
type Value struct {
storage.StoredValue
WorkflowInstance *workflow.Instance `json:"workflow_instance"`
State core.WorkflowInstanceState `json:"state"`
CreatedAt time.Time `json:"created_at"`
Queue core.Queue `json:"queue"`
Metadata *metadata.WorkflowMetadata `json:"metadata"`
LastLocked *time.Time `json:"last_locked"`
}
func (*Value) UpdateLastLocked ¶
func (v *Value) UpdateLastLocked()
Source Files
Click to show internal directories.
Click to hide internal directories.