adapter

Documentation

Overview

Package adapter implements a sample receive adapter that generates events at a regular interval.

Index

• func NewAdapter(ctx context.Context, aEnv adapter.EnvConfigAccessor, ...) adapter.Adapter
• func NewEnv() adapter.EnvConfigAccessor
• type Adapter
  • func (a *Adapter) Start(ctx context.Context) error

Functions

func NewAdapter

func NewAdapter(ctx context.Context, aEnv adapter.EnvConfigAccessor, ceClient cloudevents.Client) adapter.Adapter

func NewEnv

func NewEnv() adapter.EnvConfigAccessor

Types

type Adapter

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

Adapter generates events at a regular interval.

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context) error

Start runs the adapter. Returns if stopCh is closed or Send() returns an error.