Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubAdapter ¶
type PubSubAdapter struct {
// contains filtered or unexported fields
}
func NewPubSubAdapter ¶
func NewPubSubAdapter(ctx context.Context, 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
Click to show internal directories.
Click to hide internal directories.