server

Documentation

Index

• func NewMetaHandler(opt Option) metaHandler
• func NewMetricsHandler(opt Option) metricsHandler
• func NewSSEHandler(opt Option) (sseHandler, error)
• type GRPCServer
  • func NewGRPCServer(opt Option) (*GRPCServer, error)
  • func (s *GRPCServer) StreamAccessLogHandler(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• type Option
• type StreamServer
  • func NewStreamServer(opt Option) (*StreamServer, error)
  • func (ss *StreamServer) Events(es proto.StreamService_EventsServer) error
  • func (ss *StreamServer) Run()

Functions

func NewMetaHandler

func NewMetaHandler(opt Option) metaHandler

func NewMetricsHandler

func NewMetricsHandler(opt Option) metricsHandler

func NewSSEHandler

func NewSSEHandler(opt Option) (sseHandler, error)

Types

type GRPCServer

type GRPCServer struct {
	*grpc.Server
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(opt Option) (*GRPCServer, error)

func (*GRPCServer) StreamAccessLogHandler

func (s *GRPCServer) StreamAccessLogHandler(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

type Option

type Option struct {
	PubSuber     pubsub.PubSuber
	AccessLogger *zap.Logger
	ErrorLogger  *zap.Logger
	Config       config.Config
}

type StreamServer

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

func NewStreamServer

func NewStreamServer(opt Option) (*StreamServer, error)

func (*StreamServer) Events

func (ss *StreamServer) Events(es proto.StreamService_EventsServer) error

func (*StreamServer) Run

func (ss *StreamServer) Run()