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) GetByKey(instanceID, executionID string) storage.GetOp[*Value]
- 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 ¶
type Value ¶
type Value struct {
storage.StoredValue
WorkflowInstanceID string `json:"workflow_instance_id"`
WorkflowExecutionID string `json:"workflow_execution_id"`
CreatedAt time.Time `json:"created_at"`
WorkerID string `json:"worker_id"`
WorkerInstanceID string `json:"worker_instance_id"`
}
func (*Value) CanBeReassignedTo ¶
Click to show internal directories.
Click to hide internal directories.