grpc

Documentation

Index

• Variables
• 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 *meshes.ApplyRuleRequest) (*meshes.ApplyRuleResponse, error)
  • func (s *Service) CreateMeshInstance(ctx context.Context, req *meshes.CreateMeshInstanceRequest) (*meshes.CreateMeshInstanceResponse, error)
  • func (s *Service) MeshName(ctx context.Context, req *meshes.MeshNameRequest) (*meshes.MeshNameResponse, error)
  • func (s *Service) StreamEvents(ctx *meshes.EventsRequest, srv meshes.MeshService_StreamEventsServer) error
  • func (s *Service) SupportedOperations(ctx context.Context, req *meshes.SupportedOperationsRequest) (*meshes.SupportedOperationsResponse, error)

Variables

var (
	ErrRequestInvalid = errors.New("603", "Apply Request invalid")
)

Functions

func ErrGrpcListener

func ErrGrpcListener(err error) error

func ErrGrpcServer

func ErrGrpcServer(err error) error

func ErrPanic

func ErrPanic(r interface{}) error

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   adapter.Handler
	Channel   chan interface{}
}

Service object holds all the information about the server parameters.

func (*Service) ApplyOperation

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

ApplyOperation is the handler function for the method ApplyOperation.

func (*Service) CreateMeshInstance

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

CreateMeshInstance is the handler function for the method CreateMeshInstance.

func (*Service) MeshName

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

MeshName is the handler function for the method MeshName.

func (*Service) StreamEvents

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

StreamEvents is the handler function for the method StreamEvents.

func (*Service) SupportedOperations

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

SupportedOperations is the handler function for the method SupportedOperations.