agentadmin

Documentation

Index

• type AgentAdminServer
  • func NewServer(apiServer api.APIServer) *AgentAdminServer
  • func (s *AgentAdminServer) CreateAgent(ec echo.Context) error
  • func (*AgentAdminServer) DeleteAgentInstance(ec echo.Context, namespaceId string, id string, ...) error
  • func (*AgentAdminServer) GetAgent(ec echo.Context, id string) error
  • func (*AgentAdminServer) GetAgentAuthToken(ec echo.Context, namespaceId string, id string) error
  • func (*AgentAdminServer) GetAgentConfig(ec echo.Context, namespaceId string, configName agentmodels.AgentConfigName) error
  • func (*AgentAdminServer) GetAgentConfigBundle(ec echo.Context, namespaceId string) error
  • func (*AgentAdminServer) GetAgentInstance(ec echo.Context, namespaceId string, id string) error
  • func (*AgentAdminServer) ListAgentInstances(ec echo.Context, appID string) error
  • func (*AgentAdminServer) PutAgentConfig(ec echo.Context, namespaceId string, configName agentmodels.AgentConfigName) error
  • func (*AgentAdminServer) UpdateAgentInstance(ec echo.Context, nsID string) error
• type AgentConfigBundleDoc
  • func (d *AgentConfigBundleDoc) ToModel() (m agentmodels.AgentConfigBundle)
• type AgentConfigBundleDocItem
  • func (d *AgentConfigBundleDocItem) ToModel() (m *agentmodels.AgentConfigRef)
• type AgentConfigDoc
• type AgentDoc
• type AgentInstanceDoc
  • func (doc *AgentInstanceDoc) ToModel() (m *agentmodels.AgentInstance)
  • func (doc *AgentInstanceDoc) ToRef() (m *agentmodels.AgentInstanceRef)
• type AgentPushProxiedServer
  • func NewAgentPushProxiedServer(apiServer api.APIServer) *AgentPushProxiedServer
  • func (s *AgentPushProxiedServer) AgentDockerContainerList(ec echo.Context, namespaceId string, id string) error
  • func (s *AgentPushProxiedServer) AgentDockerImageList(ec echo.Context, namespaceId string, id string) error
  • func (s *AgentPushProxiedServer) AgentDockerImagePull(ec echo.Context, namespaceId string, id string) error
  • func (s *AgentPushProxiedServer) GetAgentDiagnostics(ec echo.Context, namespaceId string, id string) error
  • func (s *AgentPushProxiedServer) GetAgentDockerSystemInformation(ec echo.Context, namespaceId string, id string) error
  • func (s *AgentPushProxiedServer) ListAgentDockerNetowks(ec echo.Context, namespaceId string, id string) error
• type ProxyClientPool
  • func NewProxyClientPool(maxSize int) *ProxyClientPool
  • func (p *ProxyClientPool) GetClient(c context.Context, namespaceID string, instanceID string) (agentendpoint.ClientWithResponsesInterface, error)
  • func (p *ProxyClientPool) GetCutOff() time.Time
  • func (p *ProxyClientPool) Len() int
  • func (p *ProxyClientPool) Less(i int, j int) bool
  • func (p *ProxyClientPool) Pop() any
  • func (p *ProxyClientPool) Push(x any)
  • func (p *ProxyClientPool) Swap(i int, j int)

Types

type AgentAdminServer

type AgentAdminServer struct {
	api.APIServer
}

func NewServer

func NewServer(apiServer api.APIServer) *AgentAdminServer

func (*AgentAdminServer) CreateAgent

func (s *AgentAdminServer) CreateAgent(ec echo.Context) error

CreateAgent implements ServerInterface.

func (*AgentAdminServer) DeleteAgentInstance

func (*AgentAdminServer) DeleteAgentInstance(ec echo.Context, namespaceId string, id string, params admin.DeleteAgentInstanceParams) error

DeleteAgentInstance implements admin.ServerInterface.

func (*AgentAdminServer) GetAgent

func (*AgentAdminServer) GetAgent(ec echo.Context, id string) error

GetAgent implements ServerInterface.

func (*AgentAdminServer) GetAgentAuthToken

func (*AgentAdminServer) GetAgentAuthToken(ec echo.Context, namespaceId string, id string) error

GetAgentAuthToken implements admin.ServerInterface.

func (*AgentAdminServer) GetAgentConfig

func (*AgentAdminServer) GetAgentConfig(ec echo.Context, namespaceId string, configName agentmodels.AgentConfigName) error

GetAgentConfig implements admin.ServerInterface.

func (*AgentAdminServer) GetAgentConfigBundle

func (*AgentAdminServer) GetAgentConfigBundle(ec echo.Context, namespaceId string) error

GetAgentConfigBundle implements admin.ServerInterface.

func (*AgentAdminServer) GetAgentInstance

func (*AgentAdminServer) GetAgentInstance(ec echo.Context, namespaceId string, id string) error

GetAgentInstance implements admin.ServerInterface.

func (*AgentAdminServer) ListAgentInstances

func (*AgentAdminServer) ListAgentInstances(ec echo.Context, appID string) error

ListAgentInstances implements admin.ServerInterface.

func (*AgentAdminServer) PutAgentConfig

func (*AgentAdminServer) PutAgentConfig(ec echo.Context, namespaceId string, configName agentmodels.AgentConfigName) error

PutAgentConfig implements admin.ServerInterface.

func (*AgentAdminServer) UpdateAgentInstance

func (*AgentAdminServer) UpdateAgentInstance(ec echo.Context, nsID string) error

CreateAgentInstance implements admin.ServerInterface.

type AgentConfigBundleDoc

type AgentConfigBundleDoc struct {
	resdoc.ResourceDoc

	Items map[agentmodels.AgentConfigName]*AgentConfigBundleDocItem `json:"items"`
}

func (*AgentConfigBundleDoc) ToModel

func (d *AgentConfigBundleDoc) ToModel() (m agentmodels.AgentConfigBundle)

type AgentConfigBundleDocItem

type AgentConfigBundleDocItem struct {
	Updated time.Time `json:"updated"`
	Version []byte    `json:"version"`
}

func (*AgentConfigBundleDocItem) ToModel

func (d *AgentConfigBundleDocItem) ToModel() (m *agentmodels.AgentConfigRef)

type AgentConfigDoc

type AgentConfigDoc struct {
	resdoc.ResourceDoc
	Version []byte `json:"version"`
}

type AgentDoc

type AgentDoc struct {
	profile.AppDoc
}

type AgentInstanceDoc

type AgentInstanceDoc struct {
	resdoc.ResourceDoc

	Endpoint         string                         `json:"endpoint"`
	State            agentmodels.AgentInstanceState `json:"state"`
	ConfigVersion    string                         `json:"configVersion"`
	BuildID          string                         `json:"buildId"`
	TlsCertificateID string                         `json:"tlsCertificateId"`
	JwtVerfyKeyID    string                         `json:"jwtVerifyKeyId"`
}

func (*AgentInstanceDoc) ToModel

func (doc *AgentInstanceDoc) ToModel() (m *agentmodels.AgentInstance)

func (*AgentInstanceDoc) ToRef

func (doc *AgentInstanceDoc) ToRef() (m *agentmodels.AgentInstanceRef)

type AgentPushProxiedServer

type AgentPushProxiedServer struct {
	api.APIServer
	// contains filtered or unexported fields
}

func NewAgentPushProxiedServer

func NewAgentPushProxiedServer(apiServer api.APIServer) *AgentPushProxiedServer

func (*AgentPushProxiedServer) AgentDockerContainerList

func (s *AgentPushProxiedServer) AgentDockerContainerList(ec echo.Context, namespaceId string, id string) error

AgentDockerContainerList implements agentendpoint.ServerInterface.

func (*AgentPushProxiedServer) AgentDockerImageList

func (s *AgentPushProxiedServer) AgentDockerImageList(ec echo.Context, namespaceId string, id string) error

ListAgentDockerImages implements agentendpoint.ServerInterface.

func (*AgentPushProxiedServer) AgentDockerImagePull

func (s *AgentPushProxiedServer) AgentDockerImagePull(ec echo.Context, namespaceId string, id string) error

AgentDockerImagePull implements agentendpoint.ServerInterface.

func (*AgentPushProxiedServer) GetAgentDiagnostics

func (s *AgentPushProxiedServer) GetAgentDiagnostics(ec echo.Context, namespaceId string, id string) error

GetAgentDiagnostics implements admin.ServerInterface.

func (*AgentPushProxiedServer) GetAgentDockerSystemInformation

func (s *AgentPushProxiedServer) GetAgentDockerSystemInformation(ec echo.Context, namespaceId string, id string) error

GetAgentDockerSystemInformation implements admin.ServerInterface.

func (*AgentPushProxiedServer) ListAgentDockerNetowks

func (s *AgentPushProxiedServer) ListAgentDockerNetowks(ec echo.Context, namespaceId string, id string) error

ListAgentDockerNetowks implements agentendpoint.ServerInterface.

type ProxyClientPool

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

func NewProxyClientPool

func NewProxyClientPool(maxSize int) *ProxyClientPool

func (*ProxyClientPool) GetClient

func (p *ProxyClientPool) GetClient(c context.Context, namespaceID string, instanceID string) (agentendpoint.ClientWithResponsesInterface, error)

func (*ProxyClientPool) GetCutOff

func (p *ProxyClientPool) GetCutOff() time.Time

func (*ProxyClientPool) Len

func (p *ProxyClientPool) Len() int

Len implements heap.Interface.

func (*ProxyClientPool) Less

func (p *ProxyClientPool) Less(i int, j int) bool

Less implements heap.Interface.

func (*ProxyClientPool) Pop

func (p *ProxyClientPool) Pop() any

Pop implements heap.Interface.

func (*ProxyClientPool) Push

func (p *ProxyClientPool) Push(x any)

Push implements heap.Interface.

func (*ProxyClientPool) Swap

func (p *ProxyClientPool) Swap(i int, j int)

Swap implements heap.Interface.