filter

package

v1.10.1-rc1 Latest Latest Go to latest Published: Oct 7, 2021 License: Apache-2.0 Imports: 22 Imported by: 0

Details

This section is empty.

This section is empty.

func EnvAccessor() adapter.EnvConfigAccessor

EnvAccessor for configuration parameters

func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ceClient cloudevents.Client) pkgadapter.Adapter

NewAdapter creates a new Handler and its associated MessageReceiver. The caller is responsible for Start()ing the returned Handler.

func NewEnvConfig() pkgadapter.EnvConfigAccessor

NewEnvConfig satisfies env.ConfigConstructor. Returns an accessor for the source's adapter envConfig.

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

Handler parses Cloud Events, determines if they pass a filter, and sends them to a subscriber.

func (h *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (h *Handler) Start(ctx context.Context) error

Start begins to receive messages for the handler.

HTTP POST requests to the root path (/) are accepted.

This method will block until ctx is done.