Help us shape the future of Go! Take the 2026 Go Developer Survey

types

package
v0.26.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 29, 2022 License: Apache-2.0 Imports: 13 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HistoryConfig added in v0.26.0

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 added in v0.21.0

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 added in v0.20.1

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL