grpc

Documentation

Index

• type Handler
  • func (h *Handler) Ack(responseChannel chan *pb.SendEventResponse, reqGuid, connGroup string) collector.AckFunc
  • func (h *Handler) SendEvent(ctx context.Context, req *pb.SendEventRequest) (*pb.SendEventResponse, error)
• type Service
  • func NewGRPCService(c collector.Collector) *Service
  • func (s *Service) Init(context.Context) error
  • func (*Service) Name() string
  • func (s *Service) Shutdown(context.Context) error

Types

type Handler

type Handler struct {
	C collector.Collector
	pb.UnimplementedEventServiceServer
	// contains filtered or unexported fields
}

func (*Handler) Ack

func (h *Handler) Ack(responseChannel chan *pb.SendEventResponse, reqGuid, connGroup string) collector.AckFunc

func (*Handler) SendEvent

func (h *Handler) SendEvent(ctx context.Context, req *pb.SendEventRequest) (*pb.SendEventResponse, error)

type Service

type Service struct {
	Collector collector.Collector
	// contains filtered or unexported fields
}

func NewGRPCService

func NewGRPCService(c collector.Collector) *Service

func (*Service) Init

func (s *Service) Init(context.Context) error

func (*Service) Name

func (*Service) Name() string

func (*Service) Shutdown

func (s *Service) Shutdown(context.Context) error