request

Documentation

Index

• type OnewayValidatorOutbound
  • func (o OnewayValidatorOutbound) CallOneway(ctx context.Context, request *transport.Request) (transport.Ack, error)
  • func (o OnewayValidatorOutbound) Introspect() introspection.OutboundStatus
• type StreamValidatorOutbound
  • func (o StreamValidatorOutbound) CallStream(ctx context.Context, request *transport.StreamRequest) (*transport.ClientStream, error)
• type UnaryValidatorOutbound
  • func (o UnaryValidatorOutbound) Call(ctx context.Context, request *transport.Request) (*transport.Response, error)
  • func (o UnaryValidatorOutbound) Introspect() introspection.OutboundStatus

Types

type OnewayValidatorOutbound

type OnewayValidatorOutbound struct{ transport.OnewayOutbound }

OnewayValidatorOutbound wraps an Outbound to validate all outgoing oneway requests.

func (OnewayValidatorOutbound) CallOneway

func (o OnewayValidatorOutbound) CallOneway(ctx context.Context, request *transport.Request) (transport.Ack, error)

CallOneway performs the given request, failing early if the request is invalid.

func (OnewayValidatorOutbound) Introspect

func (o OnewayValidatorOutbound) Introspect() introspection.OutboundStatus

Introspect returns the introspection status of the underlying outbound.

type StreamValidatorOutbound

type StreamValidatorOutbound struct{ transport.StreamOutbound }

StreamValidatorOutbound wraps an Outbound to validate all outgoing oneway requests.

func (StreamValidatorOutbound) CallStream

func (o StreamValidatorOutbound) CallStream(ctx context.Context, request *transport.StreamRequest) (*transport.ClientStream, error)

CallStream performs the given request, failing early if the request is invalid.

type UnaryValidatorOutbound

type UnaryValidatorOutbound struct{ transport.UnaryOutbound }

UnaryValidatorOutbound wraps an Outbound to validate all outgoing unary requests.

func (UnaryValidatorOutbound) Call

func (o UnaryValidatorOutbound) Call(ctx context.Context, request *transport.Request) (*transport.Response, error)

Call performs the given request, failing early if the request is invalid.

func (UnaryValidatorOutbound) Introspect

func (o UnaryValidatorOutbound) Introspect() introspection.OutboundStatus

Introspect returns the introspection status of the underlying outbound.