googlepubsub

Documentation

Index

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

Functions

func CloseProducer

func CloseProducer(producer interface{}) error

CloseProducer closes a given producer

func Produce

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

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 Opts

type Opts struct {
	Timeout time.Duration
}

type PubsubClient

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

func NewProducer

func NewProducer(destinationConfig interface{}, o Opts) (*PubsubClient, error)

NewProducer creates a producer based on destination config

type TestConfig

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