publisher

Documentation

Index

• func NewFakePublisher() message.Publisher
• type FakePublishedEntry
• type FakePublisher
  • func (p *FakePublisher) ClearPublished()
  • func (p *FakePublisher) Close() error
  • func (p *FakePublisher) GetPublished() []*FakePublishedEntry
  • func (p *FakePublisher) Publish(topic string, messages ...*message.Message) error
• type Publisher
  • func NewPublisher(logger *zap.Logger, config *PublisherConfig) *Publisher
  • func (p *Publisher) Close() error
  • func (p *Publisher) NewMessage(ctx context.Context, payload proto.Message) (*message.Message, error)
  • func (p *Publisher) Publish(topic string, messages ...*message.Message) error
• type PublisherConfig
• type PublisherRetryConfig

Functions

func NewFakePublisher

func NewFakePublisher() message.Publisher

Types

type FakePublishedEntry

type FakePublishedEntry struct {
	Topic    string
	Messages []*message.Message
}

type FakePublisher

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

func (*FakePublisher) ClearPublished

func (p *FakePublisher) ClearPublished()

func (*FakePublisher) Close

func (p *FakePublisher) Close() error

func (*FakePublisher) GetPublished

func (p *FakePublisher) GetPublished() []*FakePublishedEntry

func (*FakePublisher) Publish

func (p *FakePublisher) Publish(topic string, messages ...*message.Message) error

type Publisher

type Publisher struct {
	Publisher message.Publisher
	Retry     *middleware.Retry
}

func NewPublisher

func NewPublisher(
	logger *zap.Logger,
	config *PublisherConfig,
) *Publisher

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) NewMessage

func (p *Publisher) NewMessage(
	ctx context.Context,
	payload proto.Message,
) (*message.Message, error)

func (*Publisher) Publish

func (p *Publisher) Publish(topic string, messages ...*message.Message) error

type PublisherConfig

type PublisherConfig struct {
	OnGCP                  bool
	ProjectId              string  // only applicable if OnGCP is true
	Name                   *string // defaults to "pubsub.Publish" if not set
	ConnectTimeoutSecs     *int
	PublishTimeoutSecs     *int
	GrpcConnectionPoolSize *int
	RetryConfig            *PublisherRetryConfig
}

type PublisherRetryConfig

type PublisherRetryConfig struct {
	MaxRetries          *int
	InitialInterval     *time.Duration
	RandomizationFactor *float64
	Multiplier          *float64
	MaxInterval         *time.Duration
	MaxElapsedTime      *time.Duration
}