server

Documentation

Index

• func AgentRPCAPIFactory(delegate modserver.AgentRPCAPIFactory) modserver.AgentRPCAPIFactory
• func ApplyDefaults(config *kascfg.ConfigurationFile)
• type AgentConnPool
• type Factory
  • func (f *Factory) Name() string
  • func (f *Factory) New(config *modserver.Config) (modserver.Module, error)

Functions

func AgentRPCAPIFactory

func AgentRPCAPIFactory(delegate modserver.AgentRPCAPIFactory) modserver.AgentRPCAPIFactory

func ApplyDefaults

func ApplyDefaults(config *kascfg.ConfigurationFile)

Types

type AgentConnPool

type AgentConnPool interface {
	Add(agentID int64, conn grpc.ClientConnInterface) error
	Remove(agentID int64)
}

type Factory

type Factory struct {
	AgentConnPool        AgentConnPool
	AgentInMemServer     *grpc.Server
	AgentInMemListener   net.Listener
	AgentInMemServerConn *grpc.ClientConn
	AgentInMemAuxCancel  context.CancelFunc
}

func (*Factory) Name

func (f *Factory) Name() string

func (*Factory) New

func (f *Factory) New(config *modserver.Config) (modserver.Module, error)