googlecloudpubsubsource

Documentation

Index

• func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ...) pkgadapter.Adapter
• func NewEnvConfig() pkgadapter.EnvConfigAccessor
• type GCloudResourceName
  • func (n *GCloudResourceName) Decode(value string) error
  • func (n *GCloudResourceName) String() string
• type MessageProcessor
• type MessageWithRawJSONData

Functions

func NewAdapter

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

NewAdapter satisfies pkgadapter.AdapterConstructor.

func NewEnvConfig

func NewEnvConfig() pkgadapter.EnvConfigAccessor

NewEnvConfig satisfies pkgadapter.EnvConfigConstructor.

Types

type GCloudResourceName

type GCloudResourceName v1alpha1.GCloudResourceName

GCloudResourceName is a fully qualified Google Cloud resource name which can be decoded by envconfig.

func (*GCloudResourceName) Decode

func (n *GCloudResourceName) Decode(value string) error

Decode implements envconfig.Decoder.

func (*GCloudResourceName) String

func (n *GCloudResourceName) String() string

String implements fmt.Stringer.

type MessageProcessor

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

MessageProcessor converts a Pub/Sub message to a CloudEvent.

type MessageWithRawJSONData

type MessageWithRawJSONData struct {
	Data json.RawMessage
	*pubsub.Message
}

MessageWithRawJSONData is an Message with RawMessage-typed JSON data.