v1

Documentation

Index

• type Agent
• type Jwt
• type KubeEventMessage
• type LogEvent
• type MessageHeader
• type Pipeline
• type PipelineMetadata
• type PipelineProcessEvent
• type ProcessLifeCycleEvent
• type Resource
• type Step
• type Subject

Types

type Agent

type Agent struct {
	Name            string `json:"name"`
	ApiVersion      string `json:"api_version"`
	TerminalBaseUrl string `bson:"terminal_base_url" json:"terminal_base_url"`
}

type Jwt

type Jwt struct {
	PublicKey *rsa.PublicKey
}

Jwt Struct of Jwt keys

type KubeEventMessage

type KubeEventMessage struct {
	Body   interface{}   `json:"body"`
	Header MessageHeader `json:"header"`
}

type LogEvent

type LogEvent struct {
	ProcessId string    `bson:"process_id"`
	Log       string    `bson:"log"`
	Step      string    `bson:"step"`
	Footmark  string    `bson:"footmark"`
	CreatedAt time.Time `bson:"created_at"`
	Claim     int       `bson:"claim" json:"claim"`
}

LogEvent LogEvent struct

type MessageHeader

type MessageHeader struct {
	Offset  int               `json:"offset"`
	Command enums.Command     `json:"command"`
	Extras  map[string]string `json:"extras"`
}

type Pipeline

type Pipeline struct {
	MetaData   PipelineMetadata `json:"_metadata" yaml:"_metadata"`
	ApiVersion string           `json:"api_version" yaml:"api_version"`
	Name       string           `json:"name"  yaml:"name"`
	ProcessId  string           `json:"process_id" yaml:"process_id"`
	Steps      []Step           `json:"steps" yaml:"steps"`
}

Pipeline pipeline stuct

type PipelineMetadata

type PipelineMetadata struct {
	CompanyId string `json:"company_id" yaml:"company_id"`
}

PipelineMetadata pipeline metadata

type PipelineProcessEvent

type PipelineProcessEvent struct {
	ProcessId string                 `bson:"process_id" json:"process_id"`
	CompanyId string                 `bson:"company_id" json:"company_id"`
	Data      map[string]interface{} `bson:"data" json:"data"`
}

PipelineProcessEvent Pipeline ProcessEvent struct

type ProcessLifeCycleEvent

type ProcessLifeCycleEvent struct {
	ProcessId string               `bson:"process_id" json:"process_id"`
	Step      string               `bson:"step" json:"step"`
	Status    enums.PROCESS_STATUS `bson:"status" json:"status"`
	Next      []string             `bson:"next" json:"next"`
	Agent     string               `bson:"agent" json:"agent"`
	CreatedAt time.Time            `bson:"created_at" json:"created_at"`
}

ProcessLifeCycleEvent Pipeline Process life cycle Event struct

type Resource

type Resource struct {
	Step           string                       `json:"step"`
	ProcessId      string                       `json:"process_id"`
	Descriptors    *[]unstructured.Unstructured `json:"descriptors" yaml:"descriptors"`
	Type           enums.RESOURCE_TYPE          `json:"type"`
	Name           string                       `json:"name"`
	Namespace      string                       `json:"namespace"`
	Replica        int32                        `json:"replica"`
	Images         []string                     `json:"images"`
	Pipeline       *Pipeline                    `bson:"pipeline" json:"pipeline"`
	Claim          int                          `bson:"claim" json:"claim"`
	RolloutRestart bool                         `bson:"rollout_restart" json:"rollout_restart"`
}

Resource agent applicable workload info.

type Step

type Step struct {
	Name string   `json:"name" yaml:"name"`
	Next []string `json:"next" yaml:"next"`
}

Step pipeline step.

type Subject

type Subject struct {
	Step, Log                  string
	Name, Namespace, ProcessId string
	EventData                  map[string]interface{}
	ProcessLabel               map[string]string
	Pipeline                   *Pipeline
}

Subject subject that observers listen