controlpoints

Documentation

Index

• func Module() fx.Option
• func Register(handler *Handler, server *grpc.Server) error
• func ToProto(cache *cache.Cache[selectors.ControlPointID]) *flowcontrolpointsv1.FlowControlPoints
• type Handler
  • func NewHandler(serviceControlPointCache *cache.Cache[selectors.ControlPointID]) *Handler
  • func (h *Handler) GetControlPoints(ctx context.Context, _ *emptypb.Empty) (*flowcontrolpointsv1.FlowControlPoints, error)

Functions

func Module

func Module() fx.Option

Module provides preview handler and registers the service.

func Register

func Register(handler *Handler, server *grpc.Server) error

Register registers the handler on grpc.Server.

func ToProto

func ToProto(cache *cache.Cache[selectors.ControlPointID]) *flowcontrolpointsv1.FlowControlPoints

ToProto converts cache to proto message.

Types

type Handler

type Handler struct {
	flowcontrolpointsv1.UnimplementedFlowControlPointsServiceServer
	// contains filtered or unexported fields
}

Handler implements FlowControlPointsService.

func NewHandler

func NewHandler(serviceControlPointCache *cache.Cache[selectors.ControlPointID]) *Handler

NewHandler returns a new Handler.

func (*Handler) GetControlPoints

func (h *Handler) GetControlPoints(ctx context.Context, _ *emptypb.Empty) (*flowcontrolpointsv1.FlowControlPoints, error)

GetControlPoints returns all control points.