pubsub

Documentation

Index

• type PubSubHandler
  • func NewPubSubHandler(logger zerolog.Logger) *PubSubHandler
  • func (handler *PubSubHandler) Do(ctx context.Context, endpointConfig *model.Endpoint) (map[string]string, interface{}, error)

Types

type PubSubHandler

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

func NewPubSubHandler

func NewPubSubHandler(logger zerolog.Logger) *PubSubHandler

func (*PubSubHandler) Do

func (handler *PubSubHandler) Do(ctx context.Context, endpointConfig *model.Endpoint) (map[string]string, interface{}, error)