store

Documentation

Index

• Constants
• func InitStorage(settings map[string]interface{}) error
• type Persistence
• type Store
  • func RegistedStore() Store

Constants

const (
	Memory     = "Memory"
	File       = "File"
	DynamoDB   = "dynamodb"
	CosmosDB   = "cosmosdb"
	RestServer = "REST"
	Postgres   = "Postgres"

	StoreType = "FLOGO_STATEFUL_STORE_TYPE"
)

Functions

func InitStorage

func InitStorage(settings map[string]interface{}) error

Types

type Persistence

type Persistence struct {
	PersistenceType string                 `json:"type"`
	Settings        map[string]interface{} `json:"settings"`
}

type Store

type Store interface {
	GetStatus(flowId string) int
	GetFlow(flowId string, metadata *metadata.Metadata) (*state.FlowInfo, error)
	GetFlows(metadata *metadata.Metadata) ([]*state.FlowInfo, error)
	GetFailedFlows(metadata *metadata.Metadata) ([]*state.FlowInfo, error)
	SaveStep(step *state.Step) error
	GetSteps(flowId string) ([]*state.Step, error)
	GetStepsNoData(flowId string) ([]map[string]string, error)
	Delete(flowId string)
	SaveSnapshot(snapshot *state.Snapshot) error
	GetSnapshot(flowId string) *state.Snapshot
	RecordStart(step *state.FlowState) error
	RecordEnd(step *state.FlowState) error
}

func RegistedStore

func RegistedStore() Store