Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
TenantID string `mapstructure:"tenant_id"`
Host string `mapstructure:"host"`
Port uint32 `mapstructure:"port"`
Insecure bool `mapstructure:"insecure"`
Auth auth.Config `mapstructure:"auth"`
TopicSelfLink string `mapstructure:"topic_self_link"`
Level string `mapstructure:"log_level"`
Format string `mapstructure:"log_format"`
}
Config the configuration for the Watch client
type WatchClient ¶
type WatchClient struct {
// contains filtered or unexported fields
}
WatchClient - stream client for connecting to the Watch Controller
func NewWatchClient ¶
func NewWatchClient(config *Config, logger logrus.FieldLogger) (*WatchClient, error)
NewWatchClient creates a WatchClient
func (WatchClient) Watch ¶
func (w WatchClient) Watch()
Watch starts a two-way stream with the Watch Controller
Click to show internal directories.
Click to hide internal directories.