sync

package

v0.29.0 Latest Latest Go to latest Published: Nov 11, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

ProcessorFunc definition of a function type for processing sync requests.

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(f map[string]string, r io.Reader, h map[string]string, d encoding.DecodeFunc) *Request

NewRequest creates a new request.

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

Decode the raw data by using the provided decoder.

type Response struct {
	Payload interface{}
}

Response definition of the sync response model.

func NewResponse(p interface{}) *Response

NewResponse creates a new response.