iacm

Documentation

Index

• type Async
• type CreateRemoteExecutionPayload
• type DefaultPipelineOverride
• type EdgeLayoutList
• type ExecutableResponse
• type ExecutionGraph
• type ExecutionNode
• type ExecutionNodeAdjacencyList
• type FailureInfoDto
• type GraphLayoutNode
• type IacmClient
  • func NewIacmClient(debug bool) *IacmClient
  • func (c *IacmClient) CreateRemoteExecution(ctx context.Context, org, project, workspace string, ...) (*RemoteExecution, error)
  • func (c *IacmClient) ExecuteRemoteExecution(ctx context.Context, org, project, workspace, id string) (*RemoteExecution, error)
  • func (c *IacmClient) GetLogToken(ctx context.Context) (string, error)
  • func (c *IacmClient) GetPipelineExecution(ctx context.Context, org, project, executionID string, stageNodeID string) (*PipelineExecutionDetail, error)
  • func (c *IacmClient) GetWorkspace(ctx context.Context, org, project, workspace string) (*Workspace, error)
  • func (c *IacmClient) UploadRemoteExecution(ctx context.Context, org, project, workspace, id string, file []byte) (*RemoteExecution, error)
• type IacmError
  • func (e *IacmError) Error() string
• type Line
• type LogClient
  • func NewLogClient() *LogClient
  • func (c *LogClient) Blob(ctx context.Context, key string) (int, error)
  • func (c *LogClient) SetToken(token string)
  • func (c *LogClient) Tail(ctx context.Context, key string) error
• type LogError
  • func (e *LogError) Error() string
• type PipelineExecutionDetail
• type PipelineExecutionError
  • func (e *PipelineExecutionError) Error() string
• type PipelineExecutionSummary
• type RemoteExecution
• type ResponseDtoPipelineExecutionDetail
• type ResponseMessage
• type Workspace

Types

type Async

type Async struct {
	LogKeys []string `json:"logKeys"`
}

type CreateRemoteExecutionPayload

type CreateRemoteExecutionPayload struct {
	CustomArguments map[string][]string `json:"custom_arguments"`
}

type DefaultPipelineOverride

type DefaultPipelineOverride struct {
	ProjectPipeline   *string `json:"project_pipeline,omitempty"`
	WorkspacePipeline *string `json:"workspace_pipeline,omitempty"`
}

type EdgeLayoutList

type EdgeLayoutList struct {
	CurrentNodeChildren []string `json:"currentNodeChildren,omitempty"`
	NextIds             []string `json:"nextIds,omitempty"`
}

type ExecutableResponse

type ExecutableResponse struct {
	Async Async `json:"async"`
}

type ExecutionGraph

type ExecutionGraph struct {
	RootNodeId           string                                `json:"rootNodeId,omitempty"`
	NodeMap              map[string]ExecutionNode              `json:"nodeMap,omitempty"`
	NodeAdjacencyListMap map[string]ExecutionNodeAdjacencyList `json:"nodeAdjacencyListMap,omitempty"`
}

type ExecutionNode

type ExecutionNode struct {
	Uuid                string               `json:"uuid,omitempty"`
	SetupId             string               `json:"setupId,omitempty"`
	Name                string               `json:"name,omitempty"`
	Identifier          string               `json:"identifier,omitempty"`
	StepType            string               `json:"stepType,omitempty"`
	Status              string               `json:"status,omitempty"`
	LogBaseKey          string               `json:"logBaseKey,omitempty"`
	ExecutableResponses []ExecutableResponse `json:"executableResponses"`
}

type ExecutionNodeAdjacencyList

type ExecutionNodeAdjacencyList struct {
	Children []string `json:"children,omitempty"`
	NextIds  []string `json:"nextIds,omitempty"`
}

type FailureInfoDto

type FailureInfoDto struct {
	Message          string            `json:"message,omitempty"`
	FailureTypeList  []string          `json:"failureTypeList,omitempty"`
	ResponseMessages []ResponseMessage `json:"responseMessages,omitempty"`
}

type GraphLayoutNode

type GraphLayoutNode struct {
	NodeType       string          `json:"nodeType,omitempty"`
	NodeGroup      string          `json:"nodeGroup,omitempty"`
	NodeIdentifier string          `json:"nodeIdentifier,omitempty"`
	Name           string          `json:"name,omitempty"`
	NodeUuid       string          `json:"nodeUuid,omitempty"`
	Status         string          `json:"status,omitempty"`
	EdgeLayoutList *EdgeLayoutList `json:"edgeLayoutList,omitempty"`
}

type IacmClient

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

func NewIacmClient

func NewIacmClient(debug bool) *IacmClient

func (*IacmClient) CreateRemoteExecution

func (c *IacmClient) CreateRemoteExecution(ctx context.Context, org, project, workspace string, customArguments map[string][]string) (*RemoteExecution, error)

func (*IacmClient) ExecuteRemoteExecution

func (c *IacmClient) ExecuteRemoteExecution(ctx context.Context, org, project, workspace, id string) (*RemoteExecution, error)

func (*IacmClient) GetLogToken

func (c *IacmClient) GetLogToken(ctx context.Context) (string, error)

func (*IacmClient) GetPipelineExecution

func (c *IacmClient) GetPipelineExecution(ctx context.Context, org, project, executionID string, stageNodeID string) (*PipelineExecutionDetail, error)

func (*IacmClient) GetWorkspace

func (c *IacmClient) GetWorkspace(ctx context.Context, org, project, workspace string) (*Workspace, error)

func (*IacmClient) UploadRemoteExecution

func (c *IacmClient) UploadRemoteExecution(ctx context.Context, org, project, workspace, id string, file []byte) (*RemoteExecution, error)

type IacmError

type IacmError struct {
	Fault     bool   `json:"fault"`
	Id        string `json:"id"`
	Message   string `json:"message"`
	Name      string `json:"name"`
	Temporary bool   `json:"temporary"`
	Timeout   bool   `json:"timeout"`
}

func (*IacmError) Error

func (e *IacmError) Error() string

type Line

type Line struct {
	Out   string
	Time  string
	Level string
}

type LogClient

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

func NewLogClient

func NewLogClient() *LogClient

func (*LogClient) Blob

func (c *LogClient) Blob(ctx context.Context, key string) (int, error)

func (*LogClient) SetToken

func (c *LogClient) SetToken(token string)

SetToken updates the authentication token for log service requests

func (*LogClient) Tail

func (c *LogClient) Tail(ctx context.Context, key string) error

type LogError

type LogError struct {
	Message string `json:"message"`
}

func (*LogError) Error

func (e *LogError) Error() string

type PipelineExecutionDetail

type PipelineExecutionDetail struct {
	PipelineExecutionSummary *PipelineExecutionSummary `json:"pipelineExecutionSummary,omitempty"`
	ExecutionGraph           *ExecutionGraph           `json:"executionGraph,omitempty"`
}

type PipelineExecutionError

type PipelineExecutionError struct {
	Status          string
	Code            string
	Message         string
	DetailedMessage string
}

func (*PipelineExecutionError) Error

func (e *PipelineExecutionError) Error() string

type PipelineExecutionSummary

type PipelineExecutionSummary struct {
	PipelineIdentifier string                     `json:"pipelineIdentifier,omitempty"`
	OrgIdentifier      string                     `json:"orgIdentifier"`
	ProjectIdentifier  string                     `json:"projectIdentifier"`
	PlanExecutionId    string                     `json:"planExecutionId,omitempty"`
	Name               string                     `json:"name,omitempty"`
	YamlVersion        string                     `json:"yamlVersion,omitempty"`
	Status             string                     `json:"status,omitempty"`
	LayoutNodeMap      map[string]GraphLayoutNode `json:"layoutNodeMap,omitempty"`
	StartingNodeId     string                     `json:"startingNodeId,omitempty"`
}

type RemoteExecution

type RemoteExecution struct {
	ID                   string              `json:"id"`
	Workspace            string              `json:"workspace"`
	Account              string              `json:"account"`
	Org                  string              `json:"org"`
	Project              string              `json:"project"`
	PipelineExecutionID  string              `json:"pipeline_execution_id"`
	PipelineExecutionURL string              `json:"pipeline_execution_url"`
	Sha256Checksum       string              `json:"sha256_checksum"`
	Created              int                 `json:"created"`
	Updated              int                 `json:"updated"`
	CustomArguments      map[string][]string `json:"custom_arguments"`
}

type ResponseDtoPipelineExecutionDetail

type ResponseDtoPipelineExecutionDetail struct {
	Status        string                   `json:"status,omitempty"`
	Data          *PipelineExecutionDetail `json:"data,omitempty"`
	CorrelationId string                   `json:"correlationId,omitempty"`
}

type ResponseMessage

type ResponseMessage struct {
	Code           string            `json:"code,omitempty"`
	Level          string            `json:"level,omitempty"`
	Message        string            `json:"message,omitempty"`
	FailureTypes   []string          `json:"failureTypes,omitempty"`
	AdditionalInfo map[string]string `json:"additionalInfo,omitempty"`
}

type Workspace

type Workspace struct {
	Account          string                              `json:"account"`
	Org              string                              `json:"org"`
	Project          string                              `json:"project"`
	Identifier       string                              `json:"identifier"`
	RepositoryPath   string                              `json:"repository_path,omitempty"`
	DefaultPipelines map[string]*DefaultPipelineOverride `json:"default_pipelines"`
}