types

Documentation

Index

• type SubscribeResponse
• type SubscriptionConfig
  • func (sc *SubscriptionConfig) CreateSubscribeRequest(target string) (*gnmi.SubscribeRequest, error)
  • 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) InsecureString() string
  • func (tc *TargetConfig) NewTLS() (*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 SubscribeResponse

type SubscribeResponse struct {
	SubscriptionName   string
	SubscriptionConfig *SubscriptionConfig
	Response           *gnmi.SubscribeResponse
}

SubscribeResponse //

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"`
}

SubscriptionConfig //

func (*SubscriptionConfig) CreateSubscribeRequest

func (sc *SubscriptionConfig) CreateSubscribeRequest(target string) (*gnmi.SubscribeRequest, error)

CreateSubscribeRequest validates the SubscriptionConfig and creates gnmi.SubscribeRequest

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"`
	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"`
	Gzip          *bool         `mapstructure:"gzip,omitempty" json:"gzip,omitempty" yaml:"gzip,omitempty"`
	Token         *string       `mapstructure:"token,omitempty" json:"token,omitempty" yaml:"token,omitempty"`
}

TargetConfig //

func (*TargetConfig) BufferSizeString

func (tc *TargetConfig) BufferSizeString() string

func (*TargetConfig) InsecureString

func (tc *TargetConfig) InsecureString() string

func (*TargetConfig) NewTLS

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

NewTLS //

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