leafGooglePubsub

README

Message-Queue-Google-Pubsub

Documentation

Index

• Constants
• func New(options ...Option) (leafMQ.MessageQueue, error)
• type Option
  • func WithAckDeadline(AckDeadline time.Duration) Option
  • func WithAsynchronous(Asynchronous bool) Option
  • func WithBufSize(BufSize int) Option
  • func WithFailedDeadline(failedDeadline time.Duration) Option
  • func WithGoogleCredentialPath(GoogleCredentialPath string) Option
  • func WithGoogleProject(googleProject string) Option
  • func WithLog(logger leafLogger.Logger) Option
  • func WithMaxExtensionDeadline(MaxExtensionDeadline time.Duration) Option
  • func WithMaxOutstandingBytes(MaxOutstandingBytes int) Option
  • func WithMaxOutstandingMessages(MaxOutstandingMessages int) Option
  • func WithMaxRetry(MaxRetry int) Option
  • func WithNumGoroutines(NumGoroutines int) Option
  • func WithSlackNotification(notification SlackNotification) Option
  • func WithSubscription(subscription map[string]string) Option
  • func WithoutSlackNotification() Option
• type SlackNotification

Constants

const (
	EventPublish = "google_pubsub_publish"
)

Functions

func New

func New(options ...Option) (leafMQ.MessageQueue, error)

Types

type Option

type Option interface {
	Apply(o *option)
}

func WithAckDeadline

func WithAckDeadline(AckDeadline time.Duration) Option

func WithAsynchronous

func WithAsynchronous(Asynchronous bool) Option

func WithBufSize

func WithBufSize(BufSize int) Option

func WithFailedDeadline

func WithFailedDeadline(failedDeadline time.Duration) Option

func WithGoogleCredentialPath

func WithGoogleCredentialPath(GoogleCredentialPath string) Option

func WithGoogleProject

func WithGoogleProject(googleProject string) Option

func WithLog

func WithLog(logger leafLogger.Logger) Option

func WithMaxExtensionDeadline

func WithMaxExtensionDeadline(MaxExtensionDeadline time.Duration) Option

func WithMaxOutstandingBytes

func WithMaxOutstandingBytes(MaxOutstandingBytes int) Option

func WithMaxOutstandingMessages

func WithMaxOutstandingMessages(MaxOutstandingMessages int) Option

func WithMaxRetry

func WithMaxRetry(MaxRetry int) Option

func WithNumGoroutines

func WithNumGoroutines(NumGoroutines int) Option

func WithSlackNotification

func WithSlackNotification(notification SlackNotification) Option

func WithSubscription

func WithSubscription(subscription map[string]string) Option

func WithoutSlackNotification

func WithoutSlackNotification() Option

type SlackNotification

type SlackNotification struct {
	Active  bool
	Hook    string
	Timeout time.Duration
}