converters

Documentation

Overview

Package converters contains pubsub message to cloudevent converters used by pubsub-based source.

Index

• Constants
• func Convert(ctx context.Context, msg *cepubsub.Message, sendMode ModeType, ...) (*cloudevents.Event, error)
• type ModeType
• type UnknownMsg
  • func (m *UnknownMsg) ProtoMessage()
  • func (m *UnknownMsg) Reset()
  • func (m *UnknownMsg) String() string

Constants

const (
	CloudAuditLogsConverter = "com.google.cloud.auditlogs"
)

const (
	CloudSchedulerConverter = "com.google.cloud.scheduler"
)

const (
	CloudStorageConverter = "com.google.cloud.storage"
)

Functions

func Convert

func Convert(ctx context.Context, msg *cepubsub.Message, sendMode ModeType, converterType string) (*cloudevents.Event, error)

Convert converts a message off the pubsub format to a source specific if there's a registered handler for the type in the converters map. If there's no registered handler, a default Pubsub one will be used.

Types

type ModeType

type ModeType string

ModeType is the type for mode enum.

const (
	// Binary mode is binary encoding.
	Binary ModeType = "binary"
	// Structured mode is structured encoding.
	Structured ModeType = "structured"
	// Push mode emulates Pub/Sub push encoding.
	Push ModeType = "push"
	// DefaultSendMode is the default choice.
	DefaultSendMode = Binary
	// The key used in the message attributes which defines the converter type.
	KnativeGCPConverter = "knative-gcp"
)

type UnknownMsg

type UnknownMsg empty.Empty

func (*UnknownMsg) ProtoMessage

func (m *UnknownMsg) ProtoMessage()

func (*UnknownMsg) Reset

func (m *UnknownMsg) Reset()

func (*UnknownMsg) String

func (m *UnknownMsg) String() string