grpc

Documentation

Index

• type AnalyticsRpcServer
  • func NewAnalyticsRpcServer(analyticsService services.AnalyticsService, c *config.Config, ...) (s *AnalyticsRpcServer)
  • func (s *AnalyticsRpcServer) GetLog(ctx context.Context, in *emptypb.Empty) (res *anrpc.GetLogsMessage, err error)
  • func (s *AnalyticsRpcServer) Listen(ctx context.Context, cancel context.CancelFunc)
  • func (s *AnalyticsRpcServer) LogData(ctx context.Context, in *anrpc.LogDataRequest) (res *emptypb.Empty, err error)

Types

type AnalyticsRpcServer

type AnalyticsRpcServer struct {
	anrpc.UnimplementedAnalyticsServer
	grpcserver.BaseGrpcServer
	// contains filtered or unexported fields
}

func NewAnalyticsRpcServer

func NewAnalyticsRpcServer(
	analyticsService services.AnalyticsService,
	c *config.Config,
	tracer opentracing.Tracer,
	logger *zap.Logger,
) (s *AnalyticsRpcServer)

func (*AnalyticsRpcServer) GetLog

func (s *AnalyticsRpcServer) GetLog(ctx context.Context, in *emptypb.Empty) (res *anrpc.GetLogsMessage, err error)

func (*AnalyticsRpcServer) Listen

func (s *AnalyticsRpcServer) Listen(ctx context.Context, cancel context.CancelFunc)

func (*AnalyticsRpcServer) LogData

func (s *AnalyticsRpcServer) LogData(ctx context.Context, in *anrpc.LogDataRequest) (res *emptypb.Empty, err error)