sync

Documentation

Index

• type ProcessorFunc
• type Request
  • func NewRequest(f map[string]string, r io.Reader, h map[string]string, d encoding.DecodeFunc) *Request
  • func (r *Request) Decode(v interface{}) error
• type Response
  • func NewResponse(p interface{}) *Response

Types

type ProcessorFunc

type ProcessorFunc func(context.Context, *Request) (*Response, error)

ProcessorFunc definition of a function type for processing sync requests.

type Request

type Request struct {
	Fields  map[string]string
	Raw     io.Reader
	Headers map[string]string
	// contains filtered or unexported fields
}

Request definition of the sync request model.

func NewRequest

func NewRequest(f map[string]string, r io.Reader, h map[string]string, d encoding.DecodeFunc) *Request

NewRequest creates a new request.

func (*Request) Decode

func (r *Request) Decode(v interface{}) error

Decode the raw data by using the provided decoder.

type Response

type Response struct {
	Payload interface{}
}

Response definition of the sync response model.

func NewResponse

func NewResponse(p interface{}) *Response

NewResponse creates a new response.