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.