Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OnewayValidatorOutbound ¶ added in v0.4.0
type OnewayValidatorOutbound struct{ transport.OnewayOutbound }
OnewayValidatorOutbound wraps an Outbound to validate all outgoing oneway requests.
func (OnewayValidatorOutbound) CallOneway ¶ added in v0.4.0
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 ¶ added in v1.0.0
func (o OnewayValidatorOutbound) Introspect() introspection.OutboundStatus
Introspect returns the introspection status of the underlying outbound.
type StreamValidatorOutbound ¶ added in v1.27.0
type StreamValidatorOutbound struct{ transport.StreamOutbound }
StreamValidatorOutbound wraps an Outbound to validate all outgoing oneway requests.
func (StreamValidatorOutbound) CallStream ¶ added in v1.27.0
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 ¶ added in v0.4.0
type UnaryValidatorOutbound struct{ transport.UnaryOutbound }
UnaryValidatorOutbound wraps an Outbound to validate all outgoing unary requests.
func (UnaryValidatorOutbound) Call ¶ added in v0.4.0
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 ¶ added in v1.0.0
func (o UnaryValidatorOutbound) Introspect() introspection.OutboundStatus
Introspect returns the introspection status of the underlying outbound.