http

Mar 2, 2020

Changes in this version

+ func SetContextHeaders(ctx context.Context, headers http.Header) context.Context

type Option

+ func WithHTTPTransport(httpTransport nethttp.RoundTripper) Option

type Transport

+ func (t *Transport) HasTracePropagation() bool

Oct 21, 2019

Changes in this version

type CodecStructured

+ DefaultEncoding Encoding

type CodecV01

+ DefaultEncoding Encoding

type CodecV02

+ DefaultEncoding Encoding

type CodecV03

+ DefaultEncoding Encoding

+ type CodecV1 struct

+ DefaultEncoding Encoding

+ func (v CodecV1) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error)

+ func (v CodecV1) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error)

type Encoding

+ const Batched

+ const BatchedV1

+ const BinaryV1

+ const StructuredV1

+ func (e Encoding) Name() string

Sep 9, 2019

Changes in this version

type TransportContext

+ StatusCode int

+ func NewTransportContextFromResponse(res *http.Response) TransportContext

Jul 24, 2019

Changes in this version

+ const DefaultShutdownTimeout

+ const TransportName

+ var LatencyMs = stats.Float64("cloudevents.io/sdk-go/transport/http/latency", ...)

+ var LatencyView = &view.View

+ func ContextWithHeader(ctx context.Context, key, value string) context.Context

+ func ContextWithLongPollTarget(ctx context.Context, target string) context.Context

+ func HeaderFrom(ctx context.Context) http.Header

+ func LongPollTargetFrom(ctx context.Context) *url.URL

+ func WithTransportContext(ctx context.Context, tcxt TransportContext) context.Context

+ type Codec struct

+ DefaultEncodingSelectionFn EncodingSelector

+ Encoding Encoding

+ func (c *Codec) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error)

+ func (c *Codec) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error)

+ type CodecObserved struct

+ func (c CodecObserved) LatencyMs() *stats.Float64Measure

+ func (c CodecObserved) MethodName() string

+ func (c CodecObserved) TraceName() string

+ type CodecStructured struct

+ Encoding Encoding

+ type CodecV01 struct

+ Encoding Encoding

+ func (v CodecV01) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error)

+ func (v CodecV01) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error)

+ type CodecV02 struct

+ Encoding Encoding

+ func (v CodecV02) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error)

+ func (v CodecV02) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error)

+ type CodecV03 struct

+ Encoding Encoding

+ func (v CodecV03) Decode(ctx context.Context, msg transport.Message) (*cloudevents.Event, error)

+ func (v CodecV03) Encode(ctx context.Context, e cloudevents.Event) (transport.Message, error)

+ type Encoding int32

+ const BatchedV03

+ const Binary

+ const BinaryV01

+ const BinaryV02

+ const BinaryV03

+ const Default

+ const Structured

+ const StructuredV01

+ const StructuredV02

+ const StructuredV03

+ const Unknown

+ func ContextBasedEncodingSelectionStrategy(ctx context.Context, e cloudevents.Event) Encoding

+ func DefaultBinaryEncodingSelectionStrategy(ctx context.Context, e cloudevents.Event) Encoding

+ func DefaultStructuredEncodingSelectionStrategy(ctx context.Context, e cloudevents.Event) Encoding

+ func (e Encoding) Codec() string

+ func (e Encoding) String() string

+ func (e Encoding) Version() string

+ type EncodingSelector func(context.Context, cloudevents.Event) Encoding

+ type Message struct

+ Body []byte

+ Header http.Header

+ func NewMessage(header http.Header, body io.ReadCloser) (*Message, error)

+ func (m *Message) Init(header http.Header, body io.ReadCloser) error

+ func (m *Message) ToRequest(req *http.Request)

+ func (m Message) CloudEventsVersion() string

+ type Middleware func(next nethttp.Handler) nethttp.Handler

+ type Option func(*Transport) error

+ func WithBinaryEncoding() Option

+ func WithContextBasedEncoding() Option

+ func WithDefaultEncodingSelector(fn EncodingSelector) Option

+ func WithEncoding(encoding Encoding) Option

+ func WithHeader(key, value string) Option

+ func WithListener(l net.Listener) Option

+ func WithLongPollTarget(targetUrl string) Option

+ func WithMethod(method string) Option

+ func WithMiddleware(middleware Middleware) Option

+ func WithPath(path string) Option

+ func WithPort(port int) Option

+ func WithShutdownTimeout(timeout time.Duration) Option

+ func WithStructuredEncoding() Option

+ func WithTarget(targetUrl string) Option

+ type Response struct

+ StatusCode int

+ func NewResponse(header http.Header, body io.ReadCloser, statusCode int) (*Response, error)

+ func (m *Response) ToResponse(resp *http.Response)

+ type Transport struct

+ Client *http.Client

+ Converter transport.Converter

+ DefaultEncodingSelectionFn EncodingSelector

+ Encoding Encoding

+ Handler *http.ServeMux

+ LongPollClient *http.Client

+ LongPollReq *http.Request

+ Path string

+ Port *int

+ Receiver transport.Receiver

+ Req *http.Request

+ ShutdownTimeout *time.Duration

+ func New(opts ...Option) (*Transport, error)

+ func (t *Transport) GetPath() string

+ func (t *Transport) GetPort() int

+ func (t *Transport) HasConverter() bool

+ func (t *Transport) MessageToEvent(ctx context.Context, msg *Message) (*cloudevents.Event, error)

+ func (t *Transport) Send(ctx context.Context, event cloudevents.Event) (*cloudevents.Event, error)

+ func (t *Transport) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (t *Transport) SetConverter(c transport.Converter)

+ func (t *Transport) SetReceiver(r transport.Receiver)

+ func (t *Transport) StartReceiver(ctx context.Context) error

+ type TransportContext struct

+ Header http.Header

+ Host string

+ IgnoreHeaderPrefixes []string

+ Method string

+ URI string

+ func NewTransportContext(req *http.Request) TransportContext

+ func TransportContextFrom(ctx context.Context) TransportContext

+ func (tx *TransportContext) AddIgnoreHeaderPrefix(prefix ...string)

+ func (tx TransportContext) AttendToHeaders() []string

+ func (tx TransportContext) String() string

+ type TransportResponseContext struct

+ Header http.Header