usp_pubsub

Documentation

Index

• type PubSubAdapter
  • func NewPubSubAdapter(conf PubSubConfig) (*PubSubAdapter, chan struct{}, error)
  • func (a *PubSubAdapter) Close() error
• type PubSubConfig
  • func (c *PubSubConfig) Validate() error

Types

type PubSubAdapter

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

func NewPubSubAdapter

func NewPubSubAdapter(conf PubSubConfig) (*PubSubAdapter, chan struct{}, error)

func (*PubSubAdapter) Close

func (a *PubSubAdapter) Close() error

type PubSubConfig

type PubSubConfig struct {
	ClientOptions       uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	SubscriptionName    string                  `json:"sub_name" yaml:"sub_name"`
	ProjectName         string                  `json:"project_name" yaml:"project_name"`
	ServiceAccountCreds string                  `json:"service_account_creds,omitempty" yaml:"service_account_creds,omitempty"`
	MaxPSBuffer         int                     `json:"max_ps_buffer,omitempty" yaml:"max_ps_buffer,omitempty"`
}

func (*PubSubConfig) Validate

func (c *PubSubConfig) Validate() error