controlpoints

Documentation

Index

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

Functions

func Module

func Module() fx.Option

Module provides preview handler and registers the service.

func Register

func Register(in RegisterIn) error

Register registers the handler on grpc.Server.

func ToProto

func ToProto(cache *cache.Cache[selectors.TypedControlPointID]) *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.TypedControlPointID]) *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.

type RegisterIn

type RegisterIn struct {
	fx.In
	Server  *grpc.Server `name:"default"`
	Handler *Handler
}

RegisterIn bundles and annotates parameters.