googlepubsub

Documentation

Index

• type Config
• type GooglePubSubProducer
  • func NewProducer(destinationConfig interface{}, o common.Opts) (*GooglePubSubProducer, error)
  • func (producer *GooglePubSubProducer) Close() error
  • func (producer *GooglePubSubProducer) Produce(jsonData json.RawMessage, _ interface{}) (statusCode int, respStatus, responseMessage string)
• type PubsubClient
• type TestConfig

Types

type Config

type Config struct {
	Credentials     string              `json:"credentials"`
	ProjectId       string              `json:"projectId"`
	EventToTopicMap []map[string]string `json:"eventToTopicMap"`
	TestConfig      TestConfig          `json:"testConfig"`
}

type GooglePubSubProducer

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

func NewProducer

func NewProducer(destinationConfig interface{}, o common.Opts) (*GooglePubSubProducer, error)

NewProducer creates a producer based on destination config

func (*GooglePubSubProducer) Close

func (producer *GooglePubSubProducer) Close() error

Close closes a given producer

func (*GooglePubSubProducer) Produce

func (producer *GooglePubSubProducer) Produce(jsonData json.RawMessage, _ interface{}) (statusCode int, respStatus, responseMessage string)

type PubsubClient

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

type TestConfig

type TestConfig struct {
	Endpoint string `json:"endpoint"`
}