cluster

type Config struct {
	NodeName       string
	BindAddr       string
	Tags           map[string]string
	StartJoinAddrs []string
}

type DelayQueue interface {
	Push(queueName string, flowId string, mesage []byte) error
	Pop(queueName string) ([]string, error)
	PushWithDelay(queueName string, flowId string, delay time.Duration, message []byte) error
}

type FlowDao interface {
	SaveFlowContext(wfName string, flowId string, flowCtx *model.FlowContext) error
	CreateAndSaveFlowContext(wFname string, flowId string, action int, dataMap map[string]any) (*model.FlowContext, error)
	AddActionOutputToFlowContext(wFname string, flowId string, action int, dataMap map[string]any) (*model.FlowContext, error)
	GetFlowContext(wfName string, flowId string) (*model.FlowContext, error)
	DeleteFlowContext(wfName string, flowId string) error
}

type Handler interface {
	Join(name, addr string, isLocal bool) error
	Leave(name string) error
	RefreshCluster()
}

type Membership struct {
	Config
	// contains filtered or unexported fields
}

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

type Queue interface {
	Push(queueName string, flowId string, mesage []byte) error
	Pop(queuName string, batchSize int) ([]string, error)
}

type Ring struct {
	RingConfig
	// contains filtered or unexported fields
}

type RingConfig struct {
	PartitionCount int
}

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

type Statehandler string