transport

Documentation

Index

• type Channel
• type HTTPError
• type HTTPRequest
• type HTTPResponse
• type InboundAcceptCodec
• type InboundCodec
• type OutboundCodec
• type RequestDecoder
• type RequestEncoder
• type ResponseDecoder
• type ResponseEncoder

Types

type Channel

type Channel interface {
	Request(request HTTPRequest) (HTTPResponse, error)
}

type HTTPError

type HTTPError interface {
	failure.Failure
	Status() int
	Headers() http.Header
}

type HTTPRequest

type HTTPRequest interface {
	Headers() http.Header
	Body() io.Reader
}

type HTTPResponse

type HTTPResponse interface {
	Status() int
	Headers() http.Header
	Body() io.Reader
}

type InboundAcceptCodec

type InboundAcceptCodec interface {
	// Decoder will be used by a server to decode HTTP Request into an invocation
	// `Batch` that will be executed using a `service`.
	Decoder() RequestDecoder
	// Encoder will be used to encode batch of invocation results into an HTTP
	// response that will be sent back to the client that initiated the request.
	Encoder() ResponseEncoder
}

type InboundCodec

type InboundCodec interface {
	Accept(request HTTPRequest) (InboundAcceptCodec, HTTPError)
}

type OutboundCodec

type OutboundCodec interface {
	RequestEncoder
	ResponseDecoder
}

type RequestDecoder

type RequestDecoder interface {
	Decode(request HTTPRequest) (message.AgentMessage, error)
}

type RequestEncoder

type RequestEncoder interface {
	Encode(message message.AgentMessage) (HTTPRequest, error)
}

type ResponseDecoder

type ResponseDecoder interface {
	Decode(response HTTPResponse) (message.AgentMessage, error)
}

type ResponseEncoder

type ResponseEncoder interface {
	Encode(message message.AgentMessage) (HTTPResponse, error)
}