gcppubsub

Documentation

Index

• Constants
• type Config
• type GCPPubSub
  • func FromConfig(ctx context.Context, config Config) (*GCPPubSub, error)
  • func New(ctx context.Context, url string) (*GCPPubSub, error)
  • func (pub *GCPPubSub) Name() string
  • func (pub *GCPPubSub) Send(ctx context.Context, body []byte) error

Constants

const (
	PublisherType = "gcp_pubsub"
)

Types

type Config

type Config struct {
	URL string `mapstructure:"url"`
}

type GCPPubSub

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

func FromConfig

func FromConfig(ctx context.Context, config Config) (*GCPPubSub, error)

func New

func New(ctx context.Context, url string) (*GCPPubSub, error)

func (*GCPPubSub) Name

func (pub *GCPPubSub) Name() string

func (*GCPPubSub) Send

func (pub *GCPPubSub) Send(ctx context.Context, body []byte) error