grpc

Documentation

Index

• func ErrGrpcListener(err error) error
• func ErrGrpcServer(err error) error
• func ErrPanic(r interface{}) error
• func Start(s *Service, tr tracing.Handler) error
• type Service
  • func (s *Service) ApplyOperation(ctx context.Context, req *proto.ApplyRuleRequest) (*proto.ApplyRuleResponse, error)
  • func (s *Service) CreateMeshInstance(ctx context.Context, req *proto.CreateMeshInstanceRequest) (*proto.CreateMeshInstanceResponse, error)
  • func (s *Service) MeshName(ctx context.Context, req *proto.MeshNameRequest) (*proto.MeshNameResponse, error)
  • func (s *Service) StreamEvents(ctx *proto.EventsRequest, srv proto.MeshService_StreamEventsServer) error
  • func (s *Service) SupportedOperations(ctx context.Context, req *proto.SupportedOperationsRequest) (*proto.SupportedOperationsResponse, error)

Functions

func ErrGrpcListener

func ErrGrpcListener(err error) error

ErrGrpcListener is the error object for grpc listener

func ErrGrpcServer

func ErrGrpcServer(err error) error

ErrGrpcServer is the error object for grpc server

func ErrPanic

func ErrPanic(r interface{}) error

ErrPanic is the error object for panic errors

func Start

func Start(s *Service, tr tracing.Handler) error

Start starts grpc server

Types

type Service

type Service struct {
	Name      string    `json:"name"`
	Port      string    `json:"port"`
	Version   string    `json:"version"`
	StartedAt time.Time `json:"startedat"`
	TraceURL  string    `json:"traceurl"`
	Handler   adaptor.Handler
}

Service object holds all the information about the server parameters.

func (*Service) ApplyOperation

func (s *Service) ApplyOperation(ctx context.Context, req *proto.ApplyRuleRequest) (*proto.ApplyRuleResponse, error)

ApplyOperation is the handler function for the method ApplyOperation.

func (*Service) CreateMeshInstance

func (s *Service) CreateMeshInstance(ctx context.Context, req *proto.CreateMeshInstanceRequest) (*proto.CreateMeshInstanceResponse, error)

CreateMeshInstance is the handler function for the method CreateMeshInstance.

func (*Service) MeshName

func (s *Service) MeshName(ctx context.Context, req *proto.MeshNameRequest) (*proto.MeshNameResponse, error)

MeshName is the handler function for the method MeshName.

func (*Service) StreamEvents

func (s *Service) StreamEvents(ctx *proto.EventsRequest, srv proto.MeshService_StreamEventsServer) error

StreamEvents is the handler function for the method StreamEvents.

func (*Service) SupportedOperations

func (s *Service) SupportedOperations(ctx context.Context, req *proto.SupportedOperationsRequest) (*proto.SupportedOperationsResponse, error)

SupportedOperations is the handler function for the method SupportedOperations.