grpc

Documentation

Index

• func EventsServerStreamInterceptor(srv interface{}, serverStream grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• func NewWrappedStream(s grpc.ServerStream) grpc.ServerStream
• func ValidateToken(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• type HealthCheckService
  • func (s *HealthCheckService) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (s *HealthCheckService) Watch(req *grpc_health_v1.HealthCheckRequest, ...) error
• type WrappedStream
  • func (w *WrappedStream) RecvMsg(m interface{}) error
  • func (w *WrappedStream) SendMsg(m interface{}) error

Functions

func EventsServerStreamInterceptor

func EventsServerStreamInterceptor(srv interface{}, serverStream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func NewWrappedStream

func NewWrappedStream(s grpc.ServerStream) grpc.ServerStream

func ValidateToken

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

Types

type HealthCheckService

type HealthCheckService struct{}

HealthCheckService implements grpc_health_v1.HealthServer

func (*HealthCheckService) Check

func (s *HealthCheckService) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

TODO add actual health checks

func (*HealthCheckService) Watch

func (s *HealthCheckService) Watch(req *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error

TODO add actual health checks

type WrappedStream

type WrappedStream struct {
	grpc.ServerStream
}

func (*WrappedStream) RecvMsg

func (w *WrappedStream) RecvMsg(m interface{}) error

func (*WrappedStream) SendMsg

func (w *WrappedStream) SendMsg(m interface{}) error