Documentation
¶
Index ¶
- type Store
- func (s *Store) AllQueuesPrefix() string
- func (s *Store) Create(item *Value) storage.PutOp[*Value]
- func (s *Store) DeleteByKey(queue, instanceID, eventID string) storage.DeleteOp
- func (s *Store) DeleteItem(item *Value) storage.DeleteValueOp[*Value]
- func (s *Store) GetAll() storage.GetMultipleOp[*Value]
- func (s *Store) GetByKey(queue, instanceID, eventID string) storage.GetOp[*Value]
- func (s *Store) GetByQueue(queue string) storage.GetMultipleOp[*Value]
- func (s *Store) Key(queue, instanceID, eventID string) string
- func (s *Store) PropagateErrors(ctx context.Context, ch chan error)
- func (s *Store) QueuePrefix(queue string) string
- func (s *Store) StartCache(ctx context.Context) error
- func (s *Store) StopCache()
- 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
}
Store is a storage implementation for activity queue items. StartCache must be called before the store can be used.
func (*Store) AllQueuesPrefix ¶
func (*Store) DeleteByKey ¶
func (*Store) DeleteItem ¶
func (s *Store) DeleteItem(item *Value) storage.DeleteValueOp[*Value]
func (*Store) GetByQueue ¶
func (s *Store) GetByQueue(queue string) storage.GetMultipleOp[*Value]
func (*Store) PropagateErrors ¶ added in v0.8.0
func (*Store) QueuePrefix ¶
type Value ¶
type Value struct {
storage.StoredValue
WorkflowInstanceID string `json:"workflow_instance_id"`
WorkflowExecutionID string `json:"workflow_execution_id"`
Queue string `json:"queue"`
Event *history.Event `json:"event"`
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.