googlecloudpubsubsource

Documentation

Index

• func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ...) pkgadapter.Adapter
• func NewEnvConfig() pkgadapter.EnvConfigAccessor
• type MessageProcessor

Functions

func NewAdapter

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

NewAdapter returns a constructor for the source's adapter.

func NewEnvConfig

func NewEnvConfig() pkgadapter.EnvConfigAccessor

NewEnvConfig returns an accessor for the source's adapter envConfig.

Types

type MessageProcessor

type MessageProcessor interface {
	Process(*pubsub.Message) ([]*cloudevents.Event, error)
}

MessageProcessor converts a Pub/Sub message to a CloudEvent.