server

Documentation

Index

• func New(ctx context.Context, app *events.App) (*grpc.Server, error)
• type HealthServer
  • func (s HealthServer) Check(ctx context.Context, req *protos.HealthCheckRequest) (*protos.HealthCheckResponse, error)
  • func (s HealthServer) Watch(req *protos.HealthCheckRequest, srv protos.Health_WatchServer) error
• type Server
  • func (s *Server) Get(ctx context.Context, request *protos.GetReq) (*protos.Event, error)
  • func (s *Server) Pub(ctx context.Context, request *protos.PubReq) (*protos.PubRes, error)
  • func (s *Server) Scan(ctx context.Context, request *protos.ScanReq) (*protos.ScanRes, error)
  • func (s *Server) Sub(req *protos.SubReq, srv protos.Events_SubServer) error
• type Service
  • func NewService(ctx context.Context, cfg *configs.Configs) (*Service, error)
  • func (service *Service) Run() error
  • func (service *Service) Start() error
  • func (service *Service) Stop() error

Functions

func New

func New(ctx context.Context, app *events.App) (*grpc.Server, error)

Types

type HealthServer

type HealthServer struct {
	protos.HealthServer
	// contains filtered or unexported fields
}

func (HealthServer) Check

func (s HealthServer) Check(ctx context.Context, req *protos.HealthCheckRequest) (*protos.HealthCheckResponse, error)

func (HealthServer) Watch

func (s HealthServer) Watch(req *protos.HealthCheckRequest, srv protos.Health_WatchServer) error

type Server

type Server struct {
	protos.EventsServer
	// contains filtered or unexported fields
}

func (*Server) Get

func (s *Server) Get(ctx context.Context, request *protos.GetReq) (*protos.Event, error)

func (*Server) Pub

func (s *Server) Pub(ctx context.Context, request *protos.PubReq) (*protos.PubRes, error)

func (*Server) Scan

func (s *Server) Scan(ctx context.Context, request *protos.ScanReq) (*protos.ScanRes, error)

func (*Server) Sub

func (s *Server) Sub(req *protos.SubReq, srv protos.Events_SubServer) error

type Service

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

func NewService

func NewService(ctx context.Context, cfg *configs.Configs) (*Service, error)

func (*Service) Run

func (service *Service) Run() error

func (*Service) Start

func (service *Service) Start() error

func (*Service) Stop

func (service *Service) Stop() error