temporal

Documentation

Index

• Constants
• func ConnectServerToTemporal(logger *slog.Logger, cfg *config.ServerConfig) (client.Client, error)
• func ConnectWorkerToTemporal(token string, temporalHost string) (client.Client, error)
• type ActivityAddTargetHistoryParam
• type ActivityAddTargetHistoryResult
• type ActivityCheckParam
• type ActivityCheckResult
• type ActivityTargetsFilterParam
• type ActivityTargetsFilterResult
• type AddTargetHistoryStatus
• type AuthHeadersProvider
  • func (p *AuthHeadersProvider) GetHeaders(ctx context.Context) (map[string]string, error)
• type Target
• type WorkflowCheckParam
• type WorkflowCheckResult
• type WorkflowHookParam
• type WorkflowHookResult

Constants

const ActivityAddTargetHistoryName = "ADD_TARGET_HISTORY"

const ActivityCheckName = "CHECK"

const ActivityTargetsFilterName = "TARGETS_FILTER"

const TEMPORAL_SERVER_QUEUE = "default"

Must be default, as we are also processing some temporal things.

const WorkflowCheckName = "CHECK_WORKFLOW"

const WorkflowHookName = "HOOK_WORKFLOW"

Functions

func ConnectServerToTemporal

func ConnectServerToTemporal(logger *slog.Logger, cfg *config.ServerConfig) (client.Client, error)

func ConnectWorkerToTemporal

func ConnectWorkerToTemporal(token string, temporalHost string) (client.Client, error)

Types

type ActivityAddTargetHistoryParam

type ActivityAddTargetHistoryParam struct {
	Target        *Target
	WorkerGroupId string
	CheckId       string
	Status        AddTargetHistoryStatus
	Note          string
}

type ActivityAddTargetHistoryResult

type ActivityAddTargetHistoryResult struct {
}

type ActivityCheckParam

type ActivityCheckParam struct {
	Script string
	Target *Target
}

type ActivityCheckResult

type ActivityCheckResult struct {
	Success bool
	Note    string
}

type ActivityTargetsFilterParam

type ActivityTargetsFilterParam struct {
	Filter string
}

type ActivityTargetsFilterResult

type ActivityTargetsFilterResult struct {
	Targets []*Target
}

type AddTargetHistoryStatus

type AddTargetHistoryStatus string

const (
	AddTargetHistoryStatusSuccess AddTargetHistoryStatus = "SUCCESS"
	AddTargetHistoryStatusFailure AddTargetHistoryStatus = "FAILURE"
	AddTargetHistoryStatusUnknown AddTargetHistoryStatus = "UNKNOWN"
)

type AuthHeadersProvider

type AuthHeadersProvider struct {
	Token string
}

func (*AuthHeadersProvider) GetHeaders

func (p *AuthHeadersProvider) GetHeaders(ctx context.Context) (map[string]string, error)

type Target

type Target struct {
	Id       string
	Name     string
	Group    string
	Metadata string
}

type WorkflowCheckParam

type WorkflowCheckParam struct {
	Script         string
	Filter         string
	CheckId        string
	WorkerGroupIds []string
}

type WorkflowCheckResult

type WorkflowCheckResult struct {
	Note string
}

type WorkflowHookParam

type WorkflowHookParam struct {
	Script string
	Filter string
	HookId string
}

type WorkflowHookResult

type WorkflowHookResult struct {
	Note string
}