types

Documentation

Index

• type HistoryConfig
• type SASL
• type SubscriptionConfig
  • func (sc *SubscriptionConfig) HeartbeatIntervalString() string
  • func (sc *SubscriptionConfig) ModeString() string
  • func (sc *SubscriptionConfig) ModelsString() string
  • func (sc *SubscriptionConfig) PathsString() string
  • func (sc *SubscriptionConfig) PrefixString() string
  • func (sc *SubscriptionConfig) QosString() string
  • func (sc *SubscriptionConfig) SampleIntervalString() string
  • func (sc *SubscriptionConfig) String() string
  • func (sc *SubscriptionConfig) SuppressRedundantString() string
  • func (sc *SubscriptionConfig) UpdatesOnlyString() string
• type TLSConfig
  • func (t *TLSConfig) Validate() error
• type TargetConfig
  • func (tc *TargetConfig) BufferSizeString() string
  • func (tc *TargetConfig) GrpcDialOptions() ([]grpc.DialOption, error)
  • func (tc *TargetConfig) InsecureString() string
  • func (tc *TargetConfig) NewTLSConfig() (*tls.Config, error)
  • func (tc *TargetConfig) OutputsString() string
  • func (tc *TargetConfig) PasswordString() string
  • func (tc *TargetConfig) SkipVerifyString() string
  • func (tc TargetConfig) String() string
  • func (tc *TargetConfig) SubscriptionString() string
  • func (tc *TargetConfig) TLSCAString() string
  • func (tc *TargetConfig) TLSCertString() string
  • func (tc *TargetConfig) TLSKeyString() string
  • func (tc *TargetConfig) UsernameString() string

Types

type HistoryConfig

type HistoryConfig struct {
	Snapshot time.Time `mapstructure:"snapshot,omitempty" json:"snapshot,omitempty"`
	Start    time.Time `mapstructure:"start,omitempty" json:"start,omitempty"`
	End      time.Time `mapstructure:"end,omitempty" json:"end,omitempty"`
}

type SASL

type SASL struct {
	User      string `mapstructure:"user,omitempty"`
	Password  string `mapstructure:"password,omitempty"`
	Mechanism string `mapstructure:"mechanism,omitempty"`
	TokenURL  string `mapstructure:"token-url,omitempty"`
}

type SubscriptionConfig

type SubscriptionConfig struct {
	Name                string                `mapstructure:"name,omitempty" json:"name,omitempty"`
	Models              []string              `mapstructure:"models,omitempty" json:"models,omitempty"`
	Prefix              string                `mapstructure:"prefix,omitempty" json:"prefix,omitempty"`
	Target              string                `mapstructure:"target,omitempty" json:"target,omitempty"`
	SetTarget           bool                  `mapstructure:"set-target,omitempty" json:"set-target,omitempty"`
	Paths               []string              `mapstructure:"paths,omitempty" json:"paths,omitempty"`
	Mode                string                `mapstructure:"mode,omitempty" json:"mode,omitempty"`
	StreamMode          string                `mapstructure:"stream-mode,omitempty" json:"stream-mode,omitempty"`
	Encoding            *string               `mapstructure:"encoding,omitempty" json:"encoding,omitempty"`
	Qos                 *uint32               `mapstructure:"qos,omitempty" json:"qos,omitempty"`
	SampleInterval      *time.Duration        `mapstructure:"sample-interval,omitempty" json:"sample-interval,omitempty"`
	HeartbeatInterval   *time.Duration        `mapstructure:"heartbeat-interval,omitempty" json:"heartbeat-interval,omitempty"`
	SuppressRedundant   bool                  `mapstructure:"suppress-redundant,omitempty" json:"suppress-redundant,omitempty"`
	UpdatesOnly         bool                  `mapstructure:"updates-only,omitempty" json:"updates-only,omitempty"`
	History             *HistoryConfig        `mapstructure:"history,omitempty" json:"history,omitempty"`
	StreamSubscriptions []*SubscriptionConfig `mapstructure:"stream-subscriptions,omitempty" json:"stream-subscriptions,omitempty"`
	Outputs             []string              `mapstructure:"outputs,omitempty" json:"outputs,omitempty"`
}

SubscriptionConfig //

func (*SubscriptionConfig) HeartbeatIntervalString

func (sc *SubscriptionConfig) HeartbeatIntervalString() string

func (*SubscriptionConfig) ModeString

func (sc *SubscriptionConfig) ModeString() string

func (*SubscriptionConfig) ModelsString

func (sc *SubscriptionConfig) ModelsString() string

func (*SubscriptionConfig) PathsString

func (sc *SubscriptionConfig) PathsString() string

func (*SubscriptionConfig) PrefixString

func (sc *SubscriptionConfig) PrefixString() string

func (*SubscriptionConfig) QosString

func (sc *SubscriptionConfig) QosString() string

func (*SubscriptionConfig) SampleIntervalString

func (sc *SubscriptionConfig) SampleIntervalString() string

func (*SubscriptionConfig) String

func (sc *SubscriptionConfig) String() string

String //

func (*SubscriptionConfig) SuppressRedundantString

func (sc *SubscriptionConfig) SuppressRedundantString() string

func (*SubscriptionConfig) UpdatesOnlyString

func (sc *SubscriptionConfig) UpdatesOnlyString() string

type TLSConfig

type TLSConfig struct {
	CaFile     string `mapstructure:"ca-file,omitempty"`
	KeyFile    string `mapstructure:"key-file,omitempty"`
	CertFile   string `mapstructure:"cert-file,omitempty"`
	SkipVerify bool   `mapstructure:"skip-verify,omitempty"`
	ClientAuth string `mapstructure:"client-auth,omitempty"`
}

func (*TLSConfig) Validate

func (t *TLSConfig) Validate() error

type TargetConfig

type TargetConfig struct {
	Name          string            `mapstructure:"name,omitempty" json:"name,omitempty" yaml:"name,omitempty"`
	Address       string            `mapstructure:"address,omitempty" json:"address,omitempty" yaml:"address,omitempty"`
	Username      *string           `mapstructure:"username,omitempty" json:"username,omitempty" yaml:"username,omitempty"`
	Password      *string           `mapstructure:"password,omitempty" json:"password,omitempty" yaml:"password,omitempty"`
	AuthScheme    string            `mapstructure:"auth-scheme,omitempty" json:"auth-scheme,omitempty" yaml:"auth-scheme,omitempty"`
	Timeout       time.Duration     `mapstructure:"timeout,omitempty" json:"timeout,omitempty" yaml:"timeout,omitempty"`
	Insecure      *bool             `mapstructure:"insecure,omitempty" json:"insecure,omitempty" yaml:"insecure,omitempty"`
	TLSCA         *string           `mapstructure:"tls-ca,omitempty" json:"tls-ca,omitempty" yaml:"tls-ca,omitempty"`
	TLSCert       *string           `mapstructure:"tls-cert,omitempty" json:"tls-cert,omitempty" yaml:"tls-cert,omitempty"`
	TLSKey        *string           `mapstructure:"tls-key,omitempty" json:"tls-key,omitempty" yaml:"tls-key,omitempty"`
	SkipVerify    *bool             `mapstructure:"skip-verify,omitempty" json:"skip-verify,omitempty" yaml:"skip-verify,omitempty"`
	TLSServerName string            `mapstructure:"tls-server-name,omitempty" json:"tls-server-name,omitempty" yaml:"tls-server-name,omitempty"`
	Subscriptions []string          `mapstructure:"subscriptions,omitempty" json:"subscriptions,omitempty" yaml:"subscriptions,omitempty"`
	Outputs       []string          `mapstructure:"outputs,omitempty" json:"outputs,omitempty" yaml:"outputs,omitempty"`
	BufferSize    uint              `mapstructure:"buffer-size,omitempty" json:"buffer-size,omitempty" yaml:"buffer-size,omitempty"`
	RetryTimer    time.Duration     `mapstructure:"retry,omitempty" json:"retry-timer,omitempty" yaml:"retry-timer,omitempty"`
	TLSMinVersion string            `mapstructure:"tls-min-version,omitempty" json:"tls-min-version,omitempty" yaml:"tls-min-version,omitempty"`
	TLSMaxVersion string            `mapstructure:"tls-max-version,omitempty" json:"tls-max-version,omitempty" yaml:"tls-max-version,omitempty"`
	TLSVersion    string            `mapstructure:"tls-version,omitempty" json:"tls-version,omitempty" yaml:"tls-version,omitempty"`
	LogTLSSecret  *bool             `mapstructure:"log-tls-secret,omitempty" json:"log-tls-secret,omitempty" yaml:"log-tls-secret,omitempty"`
	ProtoFiles    []string          `mapstructure:"proto-files,omitempty" json:"proto-files,omitempty" yaml:"proto-files,omitempty"`
	ProtoDirs     []string          `mapstructure:"proto-dirs,omitempty" json:"proto-dirs,omitempty" yaml:"proto-dirs,omitempty"`
	Tags          []string          `mapstructure:"tags,omitempty" json:"tags,omitempty" yaml:"tags,omitempty"`
	EventTags     map[string]string `mapstructure:"event-tags,omitempty" json:"event-tags,omitempty" yaml:"event-tags,omitempty"`
	Gzip          *bool             `mapstructure:"gzip,omitempty" json:"gzip,omitempty" yaml:"gzip,omitempty"`
	Token         *string           `mapstructure:"token,omitempty" json:"token,omitempty" yaml:"token,omitempty"`
	Proxy         string            `mapstructure:"proxy,omitempty" json:"proxy,omitempty" yaml:"proxy,omitempty"`
	//
	TunnelTargetType string            `mapstructure:"-" json:"tunnel-target-type,omitempty" yaml:"tunnel-target-type,omitempty"`
	Encoding         *string           `mapstructure:"encoding,omitempty" yaml:"encoding,omitempty" json:"encoding,omitempty"`
	Metadata         map[string]string `mapstructure:"metadata,omitempty" json:"metadata,omitempty" yaml:"metadata,omitempty"`
}

TargetConfig //

func (*TargetConfig) BufferSizeString

func (tc *TargetConfig) BufferSizeString() string

func (*TargetConfig) GrpcDialOptions

func (tc *TargetConfig) GrpcDialOptions() ([]grpc.DialOption, error)

GrpcDialOptions creates the grpc.dialOption list from the target's configuration

func (*TargetConfig) InsecureString

func (tc *TargetConfig) InsecureString() string

func (*TargetConfig) NewTLSConfig

func (tc *TargetConfig) NewTLSConfig() (*tls.Config, error)

NewTLSConfig //

func (*TargetConfig) OutputsString

func (tc *TargetConfig) OutputsString() string

func (*TargetConfig) PasswordString

func (tc *TargetConfig) PasswordString() string

func (*TargetConfig) SkipVerifyString

func (tc *TargetConfig) SkipVerifyString() string

func (TargetConfig) String

func (tc TargetConfig) String() string

func (*TargetConfig) SubscriptionString

func (tc *TargetConfig) SubscriptionString() string

func (*TargetConfig) TLSCAString

func (tc *TargetConfig) TLSCAString() string

func (*TargetConfig) TLSCertString

func (tc *TargetConfig) TLSCertString() string

func (*TargetConfig) TLSKeyString

func (tc *TargetConfig) TLSKeyString() string

func (*TargetConfig) UsernameString

func (tc *TargetConfig) UsernameString() string