types

Documentation

Index

• type HistoryConfig
• 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 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 string `mapstructure:"snapshot,omitempty" json:"snapshot,omitempty"`
	Start    string `mapstructure:"start,omitempty" json:"start,omitempty"`
	End      string `mapstructure:"end,omitempty" json:"end,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"`
}

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 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"`
	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:"tlsca,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"`
	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"`
	//
	TunnelTargetType string `mapstructure:"-" json:"tunnel-target-type,omitempty" yaml:"tunnel-target-type,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