services

Documentation

Index

• type CommandGrpcService
  • func NewCommandService() *CommandGrpcService
  • func (grpcService *CommandGrpcService) CommandChannel(stream proto.Commander_CommandChannelServer) error
  • func (grpcService *CommandGrpcService) Download(req *proto.DownloadRequest, download proto.Commander_DownloadServer) error
  • func (grpcService *CommandGrpcService) GetChunks() []*proto.DataChunk
  • func (grpcService *CommandGrpcService) GetConfigs() *proto.NginxConfig
  • func (grpcService *CommandGrpcService) GetContents() (confFiles, auxFiles []*proto.File)
  • func (grpcService *CommandGrpcService) GetNginxes() []*proto.NginxDetails
  • func (grpcService *CommandGrpcService) GetRegistration() *proto.AgentConnectRequest
  • func (grpcService *CommandGrpcService) Upload(upload proto.Commander_UploadServer) error
• type MetricsGrpcService
  • func NewMetricsService() *MetricsGrpcService
  • func (grpcService *MetricsGrpcService) GetEventReports() []*f5_nginx_agent_sdk_events.EventReport
  • func (grpcService *MetricsGrpcService) GetMetrics() []*proto.MetricsReport
  • func (grpcService *MetricsGrpcService) Stream(stream proto.MetricsService_StreamServer) error
  • func (grpcService *MetricsGrpcService) StreamEvents(stream proto.MetricsService_StreamEventsServer) error

Types

type CommandGrpcService

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

func NewCommandService

func NewCommandService() *CommandGrpcService

func (*CommandGrpcService) CommandChannel

func (grpcService *CommandGrpcService) CommandChannel(stream proto.Commander_CommandChannelServer) error

func (*CommandGrpcService) Download

func (grpcService *CommandGrpcService) Download(req *proto.DownloadRequest, download proto.Commander_DownloadServer) error

Download from the server to the client

func (*CommandGrpcService) GetChunks

func (grpcService *CommandGrpcService) GetChunks() []*proto.DataChunk

func (*CommandGrpcService) GetConfigs

func (grpcService *CommandGrpcService) GetConfigs() *proto.NginxConfig

func (*CommandGrpcService) GetContents

func (grpcService *CommandGrpcService) GetContents() (confFiles, auxFiles []*proto.File)

func (*CommandGrpcService) GetNginxes

func (grpcService *CommandGrpcService) GetNginxes() []*proto.NginxDetails

func (*CommandGrpcService) GetRegistration

func (grpcService *CommandGrpcService) GetRegistration() *proto.AgentConnectRequest

func (*CommandGrpcService) Upload

func (grpcService *CommandGrpcService) Upload(upload proto.Commander_UploadServer) error

Upload to the server from the client.

type MetricsGrpcService

type MetricsGrpcService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMetricsService

func NewMetricsService() *MetricsGrpcService

func (*MetricsGrpcService) GetEventReports

func (grpcService *MetricsGrpcService) GetEventReports() []*f5_nginx_agent_sdk_events.EventReport

func (*MetricsGrpcService) GetMetrics

func (grpcService *MetricsGrpcService) GetMetrics() []*proto.MetricsReport

func (*MetricsGrpcService) Stream

func (grpcService *MetricsGrpcService) Stream(stream proto.MetricsService_StreamServer) error

func (*MetricsGrpcService) StreamEvents

func (grpcService *MetricsGrpcService) StreamEvents(stream proto.MetricsService_StreamEventsServer) error