servercore

Documentation

Index

• Constants
• type AMPInfraManager
  • func (s *AMPInfraManager) ComputeStatus(stack *ampStack)
  • func (s *AMPInfraManager) Init(server *ClusterServer, clientID string, firstMessage string) error
  • func (s *AMPInfraManager) Monitor(stack *ampStack) (*[]*servergrpc.TypedOutput, error)
  • func (s *AMPInfraManager) Perrorf(format string, args ...interface{})
  • func (s *AMPInfraManager) Pinfof(format string, args ...interface{})
  • func (s *AMPInfraManager) Pregularf(format string, args ...interface{})
  • func (s *AMPInfraManager) Psuccessf(col int, format string, args ...interface{})
  • func (s *AMPInfraManager) Pull(agent *Agent, stack *ampStack) (int, int)
  • func (s *AMPInfraManager) Puserf(col int, format string, args ...interface{})
  • func (s *AMPInfraManager) Pwarnf(format string, args ...interface{})
  • func (s *AMPInfraManager) Start(stack *ampStack) error
  • func (s *AMPInfraManager) Stop(stack *ampStack) error
• type Agent
• type AmpClient
• type ClusterServer
  • func (s *ClusterServer) AgentHealth(ctx context.Context, req *servergrpc.AgentHealthRequest) (*servergrpc.ServerRet, error)
  • func (s *ClusterServer) AmpMonitor(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpMonitorAnswers, error)
  • func (s *ClusterServer) AmpPull(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpRet, error)
  • func (s *ClusterServer) AmpStart(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpRet, error)
  • func (s *ClusterServer) AmpStop(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpRet, error)
  • func (s *ClusterServer) GetAmpStatus(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpStatusAnswer, error)
  • func (s *ClusterServer) GetClientStream(stream servergrpc.ClusterServerService_GetClientStreamServer) error
  • func (s *ClusterServer) GetNodesInfo(ctx context.Context, req *servergrpc.GetNodesInfoRequest) (*servergrpc.NodesInfo, error)
  • func (s *ClusterServer) Init(version string, build string) error
  • func (s *ClusterServer) PurgeNodes(ctx context.Context, req *servergrpc.PurgeNodesRequest) (*servergrpc.PurgeNodesAnswers, error)
  • func (s *ClusterServer) RegisterAgent(ctx context.Context, req *servergrpc.RegisterRequest) (*servergrpc.ServerRet, error)
• type Logf
• type ServerConfig

Constants

const (
	//DockerURL docker url
	DockerURL = "unix:///var/run/docker.sock"
	//DockerVersion docker version
	DockerVersion = "1.24"
	//ServiceFailedTimeout max time allowed to start a service
	ServiceFailedTimeout = 30 //seconds
)

Types

type AMPInfraManager

type AMPInfraManager struct {
	Silence bool
	Verbose bool
	Force   bool
	Local   bool
	Status  string
	// contains filtered or unexported fields
}

AMPInfraManager infra stack management

func (*AMPInfraManager) ComputeStatus

func (s *AMPInfraManager) ComputeStatus(stack *ampStack)

ComputeStatus compute amp status

func (*AMPInfraManager) Init

func (s *AMPInfraManager) Init(server *ClusterServer, clientID string, firstMessage string) error

Init initialize the struct

func (*AMPInfraManager) Monitor

func (s *AMPInfraManager) Monitor(stack *ampStack) (*[]*servergrpc.TypedOutput, error)

Monitor monitor amp services

func (*AMPInfraManager) Perrorf

func (s *AMPInfraManager) Perrorf(format string, args ...interface{})

Perrorf print error

func (*AMPInfraManager) Pinfof

func (s *AMPInfraManager) Pinfof(format string, args ...interface{})

Pinfof print info

func (*AMPInfraManager) Pregularf

func (s *AMPInfraManager) Pregularf(format string, args ...interface{})

Pregularf print regular

func (*AMPInfraManager) Psuccessf

func (s *AMPInfraManager) Psuccessf(col int, format string, args ...interface{})

Psuccessf print success

func (*AMPInfraManager) Pull

func (s *AMPInfraManager) Pull(agent *Agent, stack *ampStack) (int, int)

Pull pull all amp images

func (*AMPInfraManager) Puserf

func (s *AMPInfraManager) Puserf(col int, format string, args ...interface{})

Puserf print user

func (*AMPInfraManager) Pwarnf

func (s *AMPInfraManager) Pwarnf(format string, args ...interface{})

Pwarnf print warn

func (*AMPInfraManager) Start

func (s *AMPInfraManager) Start(stack *ampStack) error

Start start amp

func (*AMPInfraManager) Stop

func (s *AMPInfraManager) Stop(stack *ampStack) error

Stop stop amp

type Agent

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

Agent struct

type AmpClient

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

AmpClient struct

type ClusterServer

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

ClusterServer struct

func (*ClusterServer) AgentHealth

func (s *ClusterServer) AgentHealth(ctx context.Context, req *servergrpc.AgentHealthRequest) (*servergrpc.ServerRet, error)

AgentHealth verifie if the server i is still available

func (*ClusterServer) AmpMonitor

func (s *ClusterServer) AmpMonitor(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpMonitorAnswers, error)

AmpMonitor amp monitor

func (*ClusterServer) AmpPull

func (s *ClusterServer) AmpPull(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpRet, error)

AmpPull amp pull

func (*ClusterServer) AmpStart

func (s *ClusterServer) AmpStart(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpRet, error)

AmpStart amp start

func (*ClusterServer) AmpStop

func (s *ClusterServer) AmpStop(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpRet, error)

AmpStop amp stop

func (*ClusterServer) GetAmpStatus

func (s *ClusterServer) GetAmpStatus(tx context.Context, req *servergrpc.AmpRequest) (*servergrpc.AmpStatusAnswer, error)

GetAmpStatus get amp status

func (*ClusterServer) GetClientStream

func (s *ClusterServer) GetClientStream(stream servergrpc.ClusterServerService_GetClientStreamServer) error

GetClientStream connect a bidirectionnal-stream

func (*ClusterServer) GetNodesInfo

func (s *ClusterServer) GetNodesInfo(ctx context.Context, req *servergrpc.GetNodesInfoRequest) (*servergrpc.NodesInfo, error)

GetNodesInfo get node info

func (*ClusterServer) Init

func (s *ClusterServer) Init(version string, build string) error

Init Connect to docker engine, get initial containers list and start the agent

func (*ClusterServer) PurgeNodes

func (s *ClusterServer) PurgeNodes(ctx context.Context, req *servergrpc.PurgeNodesRequest) (*servergrpc.PurgeNodesAnswers, error)

PurgeNodes purge nodes

func (*ClusterServer) RegisterAgent

func (s *ClusterServer) RegisterAgent(ctx context.Context, req *servergrpc.RegisterRequest) (*servergrpc.ServerRet, error)

RegisterAgent register an agent

type Logf

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

Logf logger

type ServerConfig

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

ServerConfig configuration parameters