coordinator

Documentation

Index

• Constants
• type CurrentData
• type CurrentPersistent
  • func NewCurrentPersistent(event string, data lifecycle.Current) CurrentPersistent
• type HistoryNodePersistent
  • func NewHistoryNodePersistent(data lifecycle.HistoryNode) HistoryNodePersistent
• type MetaResponse
• type MetaResponsePersistent
  • func NewMetaResponsePersistent(data runner.MetaResponse) MetaResponsePersistent
• type Repository
  • func NewRepository(db *gorm.DB) *Repository
  • func (r *Repository) SaveActionResponse(ctx context.Context, payload runner.MetaResponse) error
  • func (r *Repository) SaveHistory(ctx context.Context, record lifecycle.HistoryNode) error
  • func (r *Repository) SaveState(ctx context.Context, eventState string, payload lifecycle.Current) error

Constants

const (
	TableState          = "coordinator_states"
	TableHistory        = "coordinator_state_histories"
	TableActionResponse = "coordinator_action_responses"
)

Types

type CurrentData

type CurrentData struct {
	PID       string `gorm:"column:pid"`
	RequestID string `gorm:"column:request_id"`
	State     string
	Action    string
	Event     string
	Payload   string
	Error     string
}

type CurrentPersistent

type CurrentPersistent struct {
	domain.BasePersistent
	domain.BaseEntity
	CurrentData
	EventState string
}

func NewCurrentPersistent

func NewCurrentPersistent(event string, data lifecycle.Current) CurrentPersistent

type HistoryNodePersistent

type HistoryNodePersistent struct {
	domain.BasePersistent
	domain.BaseEntity
	CurrentData
	NodeUID string `gorm:"column:node_uid"`
}

func NewHistoryNodePersistent

func NewHistoryNodePersistent(data lifecycle.HistoryNode) HistoryNodePersistent

type MetaResponse

type MetaResponse struct {
	RequestID            string    `json:"requestID" gorm:"request_id"`
	PID                  string    `json:"pid" gorm:"column:pid"`
	ProjectUID           string    `json:"projectUID" gorm:"column:project_uid"`
	ProjectName          string    `json:"projectName" gorm:"project_name"`
	ActivityName         string    `json:"activityName" gorm:"activity_name"`
	State                string    `json:"state"`
	Event                string    `json:"event"`
	ActionName           string    `json:"actionName" gorm:"column:action_name"`
	ActionType           string    `json:"actionType" gorm:"column:action_type"`
	InternalResponseTime string    `json:"internalResponseTime" gorm:"column:internal_response_time"`
	ResponseSignature    string    `json:"responseSignature" gorm:"column:response_signature"`
	BuildAt              time.Time `json:"buildAt" gorm:"column:build_at"`
}

type MetaResponsePersistent

type MetaResponsePersistent struct {
	domain.BasePersistent
	domain.BaseEntity
	MetaResponse
}

func NewMetaResponsePersistent

func NewMetaResponsePersistent(data runner.MetaResponse) MetaResponsePersistent

type Repository

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

func NewRepository

func NewRepository(db *gorm.DB) *Repository

func (*Repository) SaveActionResponse

func (r *Repository) SaveActionResponse(ctx context.Context, payload runner.MetaResponse) error

func (*Repository) SaveHistory

func (r *Repository) SaveHistory(ctx context.Context, record lifecycle.HistoryNode) error

func (*Repository) SaveState

func (r *Repository) SaveState(ctx context.Context, eventState string, payload lifecycle.Current) error