proxy

Documentation

Index

• type MessageMutateFunc
• type PubSubProxy
  • func New(topic *pubsub.Topic, subscription *pubsub.Subscription) *PubSubProxy
  • func (proxy *PubSubProxy) Listen(ctx context.Context, preprocess MessageMutateFunc) error

Types

type MessageMutateFunc

type MessageMutateFunc func(*pubsub.Message) (*pubsub.Message, error)

type PubSubProxy

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

func New

func New(topic *pubsub.Topic, subscription *pubsub.Subscription) *PubSubProxy

func (*PubSubProxy) Listen

func (proxy *PubSubProxy) Listen(ctx context.Context, preprocess MessageMutateFunc) error