grpc

Documentation

Index

• type HealthCheckHandler
  • func NewHealthCheckHandler() *HealthCheckHandler
  • func (hch *HealthCheckHandler) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (hch *HealthCheckHandler) Watch(req *grpc_health_v1.HealthCheckRequest, ...) error
• type MessageHandler
  • func NewMessageHandler(streamer core.IMessageStreamService) *MessageHandler
  • func (mh *MessageHandler) Fetch(topic *pubsubui.TopicSubscription, stream pubsubui.PubSubUI_FetchServer) error
• type Server
  • func NewServer(config *config.Config, messageHandler *MessageHandler, ...) *Server
  • func (s *Server) Start() error

Types

type HealthCheckHandler

type HealthCheckHandler struct{}

func NewHealthCheckHandler

func NewHealthCheckHandler() *HealthCheckHandler

func (*HealthCheckHandler) Check

func (hch *HealthCheckHandler) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*HealthCheckHandler) Watch

func (hch *HealthCheckHandler) Watch(req *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error

type MessageHandler

type MessageHandler struct {
	pubsubui.UnimplementedPubSubUIServer
	// contains filtered or unexported fields
}

func NewMessageHandler

func NewMessageHandler(streamer core.IMessageStreamService) *MessageHandler

NewMessageHandler method creates a new MessageHandler

func (*MessageHandler) Fetch

func (mh *MessageHandler) Fetch(topic *pubsubui.TopicSubscription, stream pubsubui.PubSubUI_FetchServer) error

Fetch retrieves messages from PubSub and pass it to the caller

type Server

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

Server - The gRPC server

func NewServer

func NewServer(config *config.Config, messageHandler *MessageHandler, healthCheckHandler *HealthCheckHandler) *Server

NewServer method creates a new gRPC server

func (*Server) Start

func (s *Server) Start() error

Start starts the gRPC server