nativemanagement

Documentation

Index

• Constants
• type ManagementReportService
  • func (m *ManagementReportService) KeepAlive(ctx context.Context, in *management.InstancePingPkg) (*common.Commands, error)
  • func (m *ManagementReportService) ReportInstanceProperties(ctx context.Context, in *management.InstanceProperties) (*common.Commands, error)
• type Receiver
  • func (r *Receiver) Channel() <-chan *v1.SniffData
  • func (r *Receiver) DefaultConfig() string
  • func (r *Receiver) Description() string
  • func (r *Receiver) Name() string
  • func (r *Receiver) RegisterHandler(server interface{})
  • func (r *Receiver) RegisterSyncInvoker(_ module.SyncInvoker)
  • func (r *Receiver) SupportForwarders() []forwarder.Forwarder

Constants

const Name = "grpc-nativemanagement-receiver"

Types

type ManagementReportService

type ManagementReportService struct {
	management.UnimplementedManagementServiceServer
	// contains filtered or unexported fields
}

func (*ManagementReportService) KeepAlive

func (m *ManagementReportService) KeepAlive(ctx context.Context, in *management.InstancePingPkg) (*common.Commands, error)

func (*ManagementReportService) ReportInstanceProperties

func (m *ManagementReportService) ReportInstanceProperties(ctx context.Context, in *management.InstanceProperties) (*common.Commands, error)

type Receiver

type Receiver struct {
	config.CommonFields
	grpc.CommonGRPCReceiverFields
	// contains filtered or unexported fields
}

func (*Receiver) Channel

func (r *Receiver) Channel() <-chan *v1.SniffData

func (*Receiver) DefaultConfig

func (r *Receiver) DefaultConfig() string

func (*Receiver) Description

func (r *Receiver) Description() string

func (*Receiver) Name

func (r *Receiver) Name() string

func (*Receiver) RegisterHandler

func (r *Receiver) RegisterHandler(server interface{})

func (*Receiver) RegisterSyncInvoker

func (r *Receiver) RegisterSyncInvoker(_ module.SyncInvoker)

func (*Receiver) SupportForwarders

func (r *Receiver) SupportForwarders() []forwarder.Forwarder