services

Documentation

Index

• func ClearAgents()
• func ForCreate(opt *BuilderLoadOptions)
• func ForSync(opt *BuilderLoadOptions)
• func LoadAgent(ctx context.Context, agent *resources.Agent) (*coreservices.ServiceAgent, error)
• func LoadBuilder(ctx context.Context, conf *resources.Service) (*coreservices.BuilderAgent, error)
• func LoadRuntime(ctx context.Context, service *resources.Service) (*coreservices.RuntimeAgent, error)
• func NetworkMappingForRestRouteGroup(ctx context.Context, group *resources.RestRouteGroup, ...) (*basev0.NetworkMapping, error)
• func NewBuilderAgent(conf *resources.Agent, builder coreservices.Builder) agents.AgentImplementation
• func NewServiceAgent(conf *resources.Agent, service coreservices.Agent) agents.AgentImplementation
• type AddOutput
  • func Add(ctx context.Context, workspace *resources.Workspace, module *resources.Module, ...) (*AddOutput, error)
• type AgentUpdate
• type BuilderInstance
  • func (instance *BuilderInstance) Create(ctx context.Context, req *builderv0.CreateRequest, ...) (*builderv0.CreateResponse, error)
  • func (instance *BuilderInstance) Load(ctx context.Context, opts ...BuilderLoadOption) (*builderv0.LoadResponse, error)
  • func (instance *BuilderInstance) Sync(ctx context.Context, req *builderv0.SyncRequest, ...) (*builderv0.SyncResponse, error)
• type BuilderLoadOption
• type BuilderLoadOptions
• type InformationStatus
• type Instance
  • func Load(ctx context.Context, service *resources.Service) (*Instance, error)
  • func (instance *Instance) CheckCapabilities(capability agentv0.Capability_Type) error
  • func (instance *Instance) LoadBuilder(ctx context.Context) error
  • func (instance *Instance) LoadRuntime(ctx context.Context, withRuntimeCheck bool) error
  • func (instance *Instance) WithWorkspace(workspace *resources.Workspace)
• type ProcessInfo
• type RuntimeInstance
  • func (instance *RuntimeInstance) Load(ctx context.Context, env *basev0.Environment) (*runtimev0.LoadResponse, error)
• type UpdateInformation
  • func UpdateAgent(ctx context.Context, service *resources.Service) (*UpdateInformation, error)

Functions

func ClearAgents

func ClearAgents()

func ForCreate

func ForCreate(opt *BuilderLoadOptions)

func ForSync

func ForSync(opt *BuilderLoadOptions)

func LoadAgent

func LoadAgent(ctx context.Context, agent *resources.Agent) (*coreservices.ServiceAgent, error)

func LoadBuilder

func LoadBuilder(ctx context.Context, conf *resources.Service) (*coreservices.BuilderAgent, error)

func LoadRuntime

func LoadRuntime(ctx context.Context, service *resources.Service) (*coreservices.RuntimeAgent, error)

func NetworkMappingForRestRouteGroup

func NetworkMappingForRestRouteGroup(ctx context.Context, group *resources.RestRouteGroup, mappings []*basev0.NetworkMapping) (*basev0.NetworkMapping, error)

NetworkMappingForRestRouteGroup finds the proper network mapping for a given route group

func NewBuilderAgent

func NewBuilderAgent(conf *resources.Agent, builder coreservices.Builder) agents.AgentImplementation

func NewServiceAgent

func NewServiceAgent(conf *resources.Agent, service coreservices.Agent) agents.AgentImplementation

NewServiceAgent binds the agent implementation to the agent

Types

type AddOutput

type AddOutput struct {
	ReadMe string
}

func Add

func Add(ctx context.Context, workspace *resources.Workspace, module *resources.Module, input *actionservice.AddService, handler communicate.AnswerProvider) (*AddOutput, error)

type AgentUpdate

type AgentUpdate struct {
	Name string
	From string
	To   string
}

type BuilderInstance

type BuilderInstance struct {
	*Instance

	services.Builder
}

func (*BuilderInstance) Create

func (instance *BuilderInstance) Create(ctx context.Context, req *builderv0.CreateRequest, handler communicate.AnswerProvider) (*builderv0.CreateResponse, error)

func (*BuilderInstance) Load

func (instance *BuilderInstance) Load(ctx context.Context, opts ...BuilderLoadOption) (*builderv0.LoadResponse, error)

func (*BuilderInstance) Sync

func (instance *BuilderInstance) Sync(ctx context.Context, req *builderv0.SyncRequest, handler communicate.AnswerProvider) (*builderv0.SyncResponse, error)

type BuilderLoadOption

type BuilderLoadOption func(opt *BuilderLoadOptions)

type BuilderLoadOptions

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

type InformationStatus

type InformationStatus struct {
	Load  *runtimev0.LoadStatus
	Init  *runtimev0.InitStatus
	Start *runtimev0.StartStatus

	DesiredState *runtimev0.DesiredState
}

type Instance

type Instance struct {
	*resources.Service
	Workspace *resources.Workspace

	Agent services.Agent
	Info  *agentv0.AgentInformation

	Builder *BuilderInstance
	Runtime *RuntimeInstance

	ProcessInfo
	Capabilities []*agentv0.Capability
}

func Load

func Load(ctx context.Context, service *resources.Service) (*Instance, error)

func (*Instance) CheckCapabilities

func (instance *Instance) CheckCapabilities(capability agentv0.Capability_Type) error

func (*Instance) LoadBuilder

func (instance *Instance) LoadBuilder(ctx context.Context) error

func (*Instance) LoadRuntime

func (instance *Instance) LoadRuntime(ctx context.Context, withRuntimeCheck bool) error

func (*Instance) WithWorkspace

func (instance *Instance) WithWorkspace(workspace *resources.Workspace)

type ProcessInfo

type ProcessInfo struct {
	AgentPID int
}

type RuntimeInstance

type RuntimeInstance struct {
	*Instance

	services.Runtime

	IsHotReloading bool
}

func (*RuntimeInstance) Load

func (instance *RuntimeInstance) Load(ctx context.Context, env *basev0.Environment) (*runtimev0.LoadResponse, error)

type UpdateInformation

type UpdateInformation struct {
	*AgentUpdate
}

func UpdateAgent

func UpdateAgent(ctx context.Context, service *resources.Service) (*UpdateInformation, error)