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 WithShutdownTimeout(ctx context.Context, timeout time.Duration) context.Context
• func WriteHttpRequestWithAdditionalHeaders(ctx context.Context, message binding.Message, req *nethttp.Request, ...) error
• type Backoff
• type CheckRetry
• type ConnectionArgs
  • func (ca *ConnectionArgs) ConfigureTransport(transport *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)
  • func (s *HttpMessageSender) SendWithRetries(req *nethttp.Request, config *RetryConfig) (*nethttp.Response, error)
• type RetryConfig
  • func NoRetries() RetryConfig
  • func RetryConfigFromDeliverySpec(spec duckv1.DeliverySpec) (RetryConfig, error)

Constants

const (
	DefaultShutdownTimeout = time.Minute * 1
)

Functions

func CreateHandler

func CreateHandler(handler nethttp.Handler) nethttp.Handler

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 Backoff

type Backoff func(attemptNum int, resp *nethttp.Response) time.Duration

Backoff specifies a policy for how long to wait between retries. It is called after a failing request to determine the amount of time that should pass before trying again.

type CheckRetry

type CheckRetry func(ctx context.Context, resp *nethttp.Response, err error) (bool, error)

CheckRetry specifies a policy for handling retries. It is called following each request with the response and error values returned by the http.Client. If CheckRetry returns false, the Client stops retrying and returns the response to the caller. If CheckRetry returns an error, that error value is returned in lieu of the error from the request. The Client will close any response body when retrying, but if the retry is aborted it is up to the CheckRetry callback to properly close any response body before returning.

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)

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)

func (*HttpMessageSender) SendWithRetries

func (s *HttpMessageSender) SendWithRetries(req *nethttp.Request, config *RetryConfig) (*nethttp.Response, error)

type RetryConfig

type RetryConfig struct {

	// Maximum number of retries
	RetryMax int

	CheckRetry CheckRetry

	Backoff Backoff
}

func NoRetries

func NoRetries() RetryConfig

func RetryConfigFromDeliverySpec

func RetryConfigFromDeliverySpec(spec duckv1.DeliverySpec) (RetryConfig, error)