mem

Documentation

Index

• type SnapshotStore
  • func (s *SnapshotStore) Delete(flowId string)
  • func (s *SnapshotStore) GetFlow(flowId string) *state.FlowInfo
  • func (s *SnapshotStore) GetFlows() []*state.FlowInfo
  • func (s *SnapshotStore) GetSnapshot(flowId string) *state.Snapshot
  • func (s *SnapshotStore) GetStatus(flowId string) int
  • func (s *SnapshotStore) SaveSnapshot(snapshot *state.Snapshot) error
• type StepStore
  • func NewStore() *StepStore
  • func (s *StepStore) Delete(flowId string)
  • func (s *StepStore) GetFailedFlows(metadata *metadata.Metadata) ([]*state.FlowInfo, error)
  • func (s *StepStore) GetFlow(flowid string, fmetadata *metadata.Metadata) (*state.FlowInfo, error)
  • func (s *StepStore) GetFlows(metadata *metadata.Metadata) ([]*state.FlowInfo, error)
  • func (s *StepStore) GetSnapshot(flowId string) *state.Snapshot
  • func (s *StepStore) GetStatus(flowId string) int
  • func (s *StepStore) GetSteps(flowId string) ([]*state.Step, error)
  • func (s *StepStore) GetStepsNoData(flowId string) ([]map[string]string, error)
  • func (s *StepStore) RecordEnd(flowState *state.FlowState) error
  • func (s *StepStore) RecordStart(flowState *state.FlowState) error
  • func (s *StepStore) SaveSnapshot(snapshot *state.Snapshot) error
  • func (s *StepStore) SaveStep(step *state.Step) error

Types

type SnapshotStore

type SnapshotStore struct {
	// contains filtered or unexported fields
}

func (*SnapshotStore) Delete

func (s *SnapshotStore) Delete(flowId string)

func (*SnapshotStore) GetFlow

func (s *SnapshotStore) GetFlow(flowId string) *state.FlowInfo

func (*SnapshotStore) GetFlows

func (s *SnapshotStore) GetFlows() []*state.FlowInfo

func (*SnapshotStore) GetSnapshot

func (s *SnapshotStore) GetSnapshot(flowId string) *state.Snapshot

func (*SnapshotStore) GetStatus

func (s *SnapshotStore) GetStatus(flowId string) int

func (*SnapshotStore) SaveSnapshot

func (s *SnapshotStore) SaveSnapshot(snapshot *state.Snapshot) error

type StepStore

type StepStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStore

func NewStore() *StepStore

func (*StepStore) Delete

func (s *StepStore) Delete(flowId string)

func (*StepStore) GetFailedFlows

func (s *StepStore) GetFailedFlows(metadata *metadata.Metadata) ([]*state.FlowInfo, error)

func (*StepStore) GetFlow

func (s *StepStore) GetFlow(flowid string, fmetadata *metadata.Metadata) (*state.FlowInfo, error)

func (*StepStore) GetFlows

func (s *StepStore) GetFlows(metadata *metadata.Metadata) ([]*state.FlowInfo, error)

func (*StepStore) GetSnapshot

func (s *StepStore) GetSnapshot(flowId string) *state.Snapshot

func (*StepStore) GetStatus

func (s *StepStore) GetStatus(flowId string) int

func (*StepStore) GetSteps

func (s *StepStore) GetSteps(flowId string) ([]*state.Step, error)

func (*StepStore) GetStepsNoData

func (s *StepStore) GetStepsNoData(flowId string) ([]map[string]string, error)

func (*StepStore) RecordEnd

func (s *StepStore) RecordEnd(flowState *state.FlowState) error

func (*StepStore) RecordStart

func (s *StepStore) RecordStart(flowState *state.FlowState) error

func (*StepStore) SaveSnapshot

func (s *StepStore) SaveSnapshot(snapshot *state.Snapshot) error

func (*StepStore) SaveStep

func (s *StepStore) SaveStep(step *state.Step) error