kncloudevents

Documentation

Overview

* Copyright 2020 The Knative Authors * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• Constants
• func CreateHandler(handler nethttp.Handler) nethttp.Handler
• func NewDefaultClient(target ...string) (cloudevents.Client, error)
• func NewDefaultHTTPClient(t *cloudevents.HTTPTransport, opts ...client.Option) (cloudevents.Client, error)
• func WithShutdownTimeout(ctx context.Context, timeout time.Duration) context.Context
• func WriteHttpRequestWithAdditionalHeaders(ctx context.Context, message binding.Message, req *nethttp.Request, ...) error
• type ConnectionArgs
  • func (ca *ConnectionArgs) ConfigureTransport(transport *nethttp.Transport)
  • func (ca *ConnectionArgs) NewDefaultHTTPTransport() *nethttp.Transport
• type HttpMessageReceiver
  • func NewHttpMessageReceiver(port int) *HttpMessageReceiver
  • func (recv *HttpMessageReceiver) StartListen(ctx context.Context, handler nethttp.Handler) error
• type HttpMessageSender
  • func NewHttpMessageSender(connectionArgs *ConnectionArgs, target string) (*HttpMessageSender, error)
  • func (s *HttpMessageSender) NewCloudEventRequest(ctx context.Context) (*nethttp.Request, error)
  • func (s *HttpMessageSender) NewCloudEventRequestWithTarget(ctx context.Context, target string) (*nethttp.Request, error)
  • func (s *HttpMessageSender) Send(req *nethttp.Request) (*nethttp.Response, error)

Constants

const (
	DefaultShutdownTimeout = time.Minute * 1
)

Functions

func CreateHandler

func CreateHandler(handler nethttp.Handler) nethttp.Handler

func NewDefaultClient

func NewDefaultClient(target ...string) (cloudevents.Client, error)

func NewDefaultHTTPClient

func NewDefaultHTTPClient(t *cloudevents.HTTPTransport, opts ...client.Option) (cloudevents.Client, error)

NewDefaultHTTPClient creates a new client from an HTTP transport.

func WithShutdownTimeout

func WithShutdownTimeout(ctx context.Context, timeout time.Duration) context.Context

func WriteHttpRequestWithAdditionalHeaders

func WriteHttpRequestWithAdditionalHeaders(ctx context.Context, message binding.Message, req *nethttp.Request, additionalHeaders nethttp.Header, transformers ...binding.Transformer) error

Types

type ConnectionArgs

type ConnectionArgs struct {
	// MaxIdleConns refers to the max idle connections, as in net/http/transport.
	MaxIdleConns int
	// MaxIdleConnsPerHost refers to the max idle connections per host, as in net/http/transport.
	MaxIdleConnsPerHost int
}

ConnectionArgs allow to configure connection parameters to the underlying HTTP Client transport.

func (*ConnectionArgs) ConfigureTransport

func (ca *ConnectionArgs) ConfigureTransport(transport *nethttp.Transport)

func (*ConnectionArgs) NewDefaultHTTPTransport

func (ca *ConnectionArgs) NewDefaultHTTPTransport() *nethttp.Transport

type HttpMessageReceiver

type HttpMessageReceiver struct {
	// contains filtered or unexported fields
}

func NewHttpMessageReceiver

func NewHttpMessageReceiver(port int) *HttpMessageReceiver

func (*HttpMessageReceiver) StartListen

func (recv *HttpMessageReceiver) StartListen(ctx context.Context, handler nethttp.Handler) error

Blocking

type HttpMessageSender

type HttpMessageSender struct {
	Client *nethttp.Client
	Target string
}

func NewHttpMessageSender

func NewHttpMessageSender(connectionArgs *ConnectionArgs, target string) (*HttpMessageSender, error)

func (*HttpMessageSender) NewCloudEventRequest

func (s *HttpMessageSender) NewCloudEventRequest(ctx context.Context) (*nethttp.Request, error)

func (*HttpMessageSender) NewCloudEventRequestWithTarget

func (s *HttpMessageSender) NewCloudEventRequestWithTarget(ctx context.Context, target string) (*nethttp.Request, error)

func (*HttpMessageSender) Send

func (s *HttpMessageSender) Send(req *nethttp.Request) (*nethttp.Response, error)