receiver

Documentation

Index

• type Service
  • func NewService(mbm *models.MetricsBucket) *Service
  • func (s *Service) Collect(ctx context.Context, req *qanpb.CollectRequest) (*qanpb.CollectResponse, error)

Types

type Service

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

Service implements gRPC service to communicate with agent.

func NewService

func NewService(mbm *models.MetricsBucket) *Service

NewService create new insstance of Service.

func (*Service) Collect

func (s *Service) Collect(ctx context.Context, req *qanpb.CollectRequest) (*qanpb.CollectResponse, error)

Collect implements rpc to store data collected from slowlog/perf schema etc.