Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v1.0.2
type GooglePubSubProducer struct {
// contains filtered or unexported fields
}
func NewProducer ¶
func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*GooglePubSubProducer, error)
NewProducer creates a producer based on destination config
func (*GooglePubSubProducer) Close ¶ added in v1.0.2
func (producer *GooglePubSubProducer) Close() error
Close closes a given producer
func (*GooglePubSubProducer) Produce ¶ added in v1.0.2
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"`
}
Click to show internal directories.
Click to hide internal directories.