request

Documentation

Index

• func Validate(ctx context.Context, req *transport.Request) (*transport.Request, error)
• func ValidateOneway(ctx context.Context, req *transport.Request) (*transport.Request, error)
• func ValidateUnary(ctx context.Context, req *transport.Request) (*transport.Request, error)
• type OnewayValidatorOutbound
  • func (o OnewayValidatorOutbound) CallOneway(ctx context.Context, request *transport.Request) (transport.Ack, error)
• type UnaryValidatorOutbound
  • func (o UnaryValidatorOutbound) Call(ctx context.Context, request *transport.Request) (*transport.Response, error)
• type Validator
  • func (v *Validator) ParseTTL(ctx context.Context, ttl string) (context.Context, func())
  • func (v *Validator) Validate(ctx context.Context) (*transport.Request, error)
  • func (v *Validator) ValidateOneway(ctx context.Context) (*transport.Request, error)
  • func (v *Validator) ValidateUnary(ctx context.Context) (*transport.Request, error)

Functions

func Validate

func Validate(ctx context.Context, req *transport.Request) (*transport.Request, error)

Validate is a shortcut for the case where a request needs to be validated without changing the TTL. This should be used to validate all request types

func ValidateOneway

func ValidateOneway(ctx context.Context, req *transport.Request) (*transport.Request, error)

ValidateOneway validates a oneway request. This should be used after a successful Validate()

func ValidateUnary

func ValidateUnary(ctx context.Context, req *transport.Request) (*transport.Request, error)

ValidateUnary validates a unary request. This should be used after a successful Validate()

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.

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.

type Validator

type Validator struct {
	Request *transport.Request
	// contains filtered or unexported fields
}

Validator helps validate requests.

v := Validator{Request: request}
v.Validate()
...
v.ParseTTL(ttlstring)
request, err := v.ValidateUnary()

func (*Validator) ParseTTL

func (v *Validator) ParseTTL(ctx context.Context, ttl string) (context.Context, func())

ParseTTL takes a context parses the given TTL, clamping the context to that TTL and as a side-effect, tracking any errors encountered while attempting to parse and validate that TTL. Should only be used for unary requests

func (*Validator) Validate

func (v *Validator) Validate(ctx context.Context) (*transport.Request, error)

Validate checks that the request inside this validator is valid and returns either the validated request or an error. This should be used to check all requests, prior to the RPC type specifc validation.

func (*Validator) ValidateOneway

func (v *Validator) ValidateOneway(ctx context.Context) (*transport.Request, error)

ValidateOneway validates a oneway request. This should be used after a successful Validate()

func (*Validator) ValidateUnary

func (v *Validator) ValidateUnary(ctx context.Context) (*transport.Request, error)

ValidateUnary validates a unary request. This should be used after a successful v.Validate()