validator

Documentation

Index

• Variables
• func ProvideFlowcontrolHandler(in ConstructorIn) (flowcontrolv1.FlowControlServiceServer, error)
• func Register(server *grpc.Server, handler flowcontrolv1.FlowControlServiceServer)
• type CommonHandler
  • func (c *CommonHandler) CheckWithValues(ctx context.Context, services []string, controlPoint string, ...) *flowcontrolv1.CheckResponse
• type ConstructorIn
• type FlowControlHandler
  • func (f *FlowControlHandler) Check(ctx context.Context, req *flowcontrolv1.CheckRequest) (*flowcontrolv1.CheckResponse, error)
• type TraceHandler
  • func (t TraceHandler) Export(ctx context.Context, req *tracev1.ExportTraceServiceRequest) (*tracev1.ExportTraceServiceResponse, error)

Variables

var Module = fx.Options(
	fx.Provide(ProvideFlowcontrolHandler),
	fx.Invoke(Register),
)

Module .

Functions

func ProvideFlowcontrolHandler

func ProvideFlowcontrolHandler(in ConstructorIn) (flowcontrolv1.FlowControlServiceServer, error)

ProvideFlowcontrolHandler .

func Register

func Register(server *grpc.Server, handler flowcontrolv1.FlowControlServiceServer)

Register registers flowcontrol service on a grpc server.

Types

type CommonHandler

type CommonHandler struct {
	check.HandlerWithValues

	Rejects  int64
	Rejected int64
}

CommonHandler implements common.HandlerWithValues.

func (*CommonHandler) CheckWithValues

func (c *CommonHandler) CheckWithValues(ctx context.Context, services []string, controlPoint string, labels map[string]string) *flowcontrolv1.CheckResponse

CheckWithValues is a dummy function for creating *flowcontrolv1.CheckResponse from given parameters.

type ConstructorIn

type ConstructorIn struct {
	fx.In
}

ConstructorIn .

type FlowControlHandler

type FlowControlHandler struct {
	flowcontrolv1.UnimplementedFlowControlServiceServer

	CommonHandler check.HandlerWithValues
}

FlowControlHandler implements FlowControlService.

func (*FlowControlHandler) Check

func (f *FlowControlHandler) Check(ctx context.Context, req *flowcontrolv1.CheckRequest) (*flowcontrolv1.CheckResponse, error)

Check is a dummy Check handler.

type TraceHandler

type TraceHandler struct {
	tracev1.UnimplementedTraceServiceServer
}

TraceHandler implements ExportTraceService.

func (TraceHandler) Export

func (t TraceHandler) Export(ctx context.Context, req *tracev1.ExportTraceServiceRequest) (*tracev1.ExportTraceServiceResponse, error)

Export is a dummy Export handler.