pubsub

Documentation

Index

• type Listener
  • func New() *Listener
  • func (v *Listener) GetApiPath() string
  • func (v *Listener) GetName() string
  • func (v *Listener) Initialize(ctx context.Context) error
  • func (v *Listener) ParsePayload(ctx context.Context, log *zap.Logger, payload []byte) (*message.EventData, *http.ErrorDetail)

Types

type Listener

type Listener struct {
	Name    string
	ApiPath string
}

func New

func New() *Listener

func (*Listener) GetApiPath

func (v *Listener) GetApiPath() string

func (*Listener) GetName

func (v *Listener) GetName() string

func (*Listener) Initialize

func (v *Listener) Initialize(ctx context.Context) error

func (*Listener) ParsePayload

func (v *Listener) ParsePayload(ctx context.Context, log *zap.Logger, payload []byte) (*message.EventData, *http.ErrorDetail)

https://cloud.google.com/pubsub/docs/publish-receive-messages-client-library https://cloud.google.com/pubsub/docs/samples/pubsub-subscribe-avro-records