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

types

package
v0.1.7 Latest Latest
Warning

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

Go to latest
Published: May 6, 2024 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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" yaml:"name,omitempty" json:"name,omitempty"`
	Address       string            `mapstructure:"address,omitempty" yaml:"address,omitempty" json:"address,omitempty"`
	Username      *string           `mapstructure:"username,omitempty" yaml:"username,omitempty" json:"username,omitempty"`
	Password      *string           `mapstructure:"password,omitempty" yaml:"password,omitempty" json:"password,omitempty"`
	AuthScheme    string            `mapstructure:"auth-scheme,omitempty" yaml:"auth-scheme,omitempty" json:"auth-scheme,omitempty"`
	Timeout       time.Duration     `mapstructure:"timeout,omitempty" yaml:"timeout,omitempty" json:"timeout,omitempty"`
	Insecure      *bool             `mapstructure:"insecure,omitempty" yaml:"insecure,omitempty" json:"insecure,omitempty"`
	TLSCA         *string           `mapstructure:"tls-ca,omitempty" yaml:"tls-ca,omitempty" json:"tls-ca,omitempty"`
	TLSCert       *string           `mapstructure:"tls-cert,omitempty" yaml:"tls-cert,omitempty" json:"tls-cert,omitempty"`
	TLSKey        *string           `mapstructure:"tls-key,omitempty" yaml:"tls-key,omitempty" json:"tls-key,omitempty"`
	SkipVerify    *bool             `mapstructure:"skip-verify,omitempty" yaml:"skip-verify,omitempty" json:"skip-verify,omitempty"`
	TLSServerName string            `mapstructure:"tls-server-name,omitempty" yaml:"tls-server-name,omitempty" json:"tls-server-name,omitempty"`
	Subscriptions []string          `mapstructure:"subscriptions,omitempty" yaml:"subscriptions,omitempty" json:"subscriptions,omitempty"`
	Outputs       []string          `mapstructure:"outputs,omitempty" yaml:"outputs,omitempty" json:"outputs,omitempty"`
	BufferSize    uint              `mapstructure:"buffer-size,omitempty" yaml:"buffer-size,omitempty" json:"buffer-size,omitempty"`
	RetryTimer    time.Duration     `mapstructure:"retry,omitempty" yaml:"retry-timer,omitempty" json:"retry-timer,omitempty"`
	TLSMinVersion string            `mapstructure:"tls-min-version,omitempty" yaml:"tls-min-version,omitempty" json:"tls-min-version,omitempty"`
	TLSMaxVersion string            `mapstructure:"tls-max-version,omitempty" yaml:"tls-max-version,omitempty" json:"tls-max-version,omitempty"`
	TLSVersion    string            `mapstructure:"tls-version,omitempty" yaml:"tls-version,omitempty" json:"tls-version,omitempty"`
	LogTLSSecret  *bool             `mapstructure:"log-tls-secret,omitempty" yaml:"log-tls-secret,omitempty" json:"log-tls-secret,omitempty"`
	ProtoFiles    []string          `mapstructure:"proto-files,omitempty" yaml:"proto-files,omitempty" json:"proto-files,omitempty"`
	ProtoDirs     []string          `mapstructure:"proto-dirs,omitempty" yaml:"proto-dirs,omitempty" json:"proto-dirs,omitempty"`
	Tags          []string          `mapstructure:"tags,omitempty" yaml:"tags,omitempty" json:"tags,omitempty"`
	EventTags     map[string]string `mapstructure:"event-tags,omitempty" yaml:"event-tags,omitempty" json:"event-tags,omitempty"`
	Gzip          *bool             `mapstructure:"gzip,omitempty" yaml:"gzip,omitempty" json:"gzip,omitempty"`
	Token         *string           `mapstructure:"token,omitempty" yaml:"token,omitempty" json:"token,omitempty"`
	Proxy         string            `mapstructure:"proxy,omitempty" yaml:"proxy,omitempty" json:"proxy,omitempty"`
	//
	TunnelTargetType string            `mapstructure:"-" yaml:"tunnel-target-type,omitempty" json:"tunnel-target-type,omitempty"`
	Encoding         *string           `mapstructure:"encoding,omitempty" yaml:"encoding,omitempty" json:"encoding,omitempty"`
	Metadata         map[string]string `mapstructure:"metadata,omitempty" yaml:"metadata,omitempty" json:"metadata,omitempty"`
	CipherSuites     []string          `mapstructure:"cipher-suites,omitempty" yaml:"cipher-suites,omitempty" json:"cipher-suites,omitempty"`
	TCPKeepalive     time.Duration     `mapstructure:"tcp-keepalive,omitempty" yaml:"tcp-keepalive,omitempty" json:"tcp-keepalive,omitempty"`
	GRPCKeepalive    *clientKeepalive  `mapstructure:"grpc-keepalive,omitempty" yaml:"grpc-keepalive,omitempty" json:"grpc-keepalive,omitempty"`
	// contains filtered or unexported fields
}

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) SetTLSConfig added in v0.1.6

func (tc *TargetConfig) SetTLSConfig(tlsConfig *tls.Config)

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