collector

Aug 17, 2021

Changes in this version

type Collector

+ func New(config *Config, targetConfigs map[string]*types.TargetConfig, ...) *Collector

type CollectorOption

+ func WithCache(ch *cache.Cache) CollectorOption

+ func WithPrometheusRegistry(reg *prometheus.Registry) CollectorOption

Jul 14, 2021

Changes in this version

type TargetConfig

+ Token *string

Jun 7, 2021

Changes in this version

type SubscribeResponse

+ SubscriptionConfig *SubscriptionConfig

type SubscriptionConfig

+ SetTarget bool

May 28, 2021

Changes in this version

type Collector

+ func (c *Collector) CreateTarget(name string) error

Mar 23, 2021

Changes in this version

type Target

+ func (t *Target) ReadSubscriptions() (chan *SubscribeResponse, chan *TargetError)

+ func (t *Target) SubscribeOnce(ctx context.Context, req *gnmi.SubscribeRequest, subscriptionName string) (chan *gnmi.SubscribeResponse, chan error)

type TargetConfig

+ Gzip *bool

Mar 11, 2021

Changes in this version

type CollectorOption

+ func WithProtoDescriptor(d desc.Descriptor) CollectorOption

type TargetConfig

+ ProtoDirs []string

+ ProtoFiles []string

Mar 2, 2021

Changes in this version

type Collector

+ func (c *Collector) InitTargets() error

+ func (c *Collector) SubscribeOnce(ctx context.Context, tName string) error

+ func (c *Collector) TargetSubscribeOnce(ctx context.Context, name string)

+ func (c *Collector) TargetSubscribePoll(ctx context.Context, name string)

+ func (c *Collector) TargetSubscribeStream(ctx context.Context, name string)

type TargetConfig

+ Tags []string

Jan 28, 2021

Changes in this version

type Collector

+ Inputs map[string]inputs.Input

+ func (c *Collector) AddInput(name string, cfg map[string]interface{}) error

+ func (c *Collector) InitInput(ctx context.Context, name string)

+ func (c *Collector) InitInputs(ctx context.Context)

+ func (c *Collector) InitLocker(ctx context.Context) error

+ func (c *Collector) StopTarget(name string) error

type CollectorOption

+ func WithInputs(inputsConfig map[string]map[string]interface{}) CollectorOption

+ func WithLocker(lockerConfig map[string]interface{}) CollectorOption

type Config

+ ClusterName string

+ LockRetryTimer time.Duration

+ Name string

Dec 14, 2020

Changes in this version

type Collector

+ EventProcessorsConfig map[string]map[string]interface{}

type CollectorOption

+ func WithEventProcessors(eps map[string]map[string]interface{}) CollectorOption

Nov 28, 2020

Changes in this version

type Collector

+ func (c *Collector) AddOutput(name string, cfg map[string]interface{}) error

+ func (c *Collector) AddSubscriptionConfig(sc *SubscriptionConfig) error

+ func (c *Collector) AddTarget(tc *TargetConfig) error

+ func (c *Collector) DeleteOutput(name string) error

+ func (c *Collector) DeleteSubscription(name string) error

+ func (c *Collector) DeleteTarget(name string) error

+ func (c *Collector) InitOutput(ctx context.Context, name string)

+ func (c *Collector) InitOutputs(ctx context.Context)

type Target

+ func (t *Target) Stop()

Nov 25, 2020

Changes in this version

type Collector

+ func (c *Collector) Capabilities(ctx context.Context, tName string, ext ...*gnmi_ext.Extension) (*gnmi.CapabilityResponse, error)

+ func (c *Collector) Get(ctx context.Context, tName string, req *gnmi.GetRequest) (*gnmi.GetResponse, error)

+ func (c *Collector) GetModels(ctx context.Context, tName string) ([]*gnmi.ModelData, error)

+ func (c *Collector) Set(ctx context.Context, tName string, req *gnmi.SetRequest) (*gnmi.SetResponse, error)

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) SuppressRedundantString() string

+ func (sc *SubscriptionConfig) UpdatesOnlyString() string

type TargetConfig

+ TLSMaxVersion string

+ TLSMinVersion string

+ TLSVersion string

+ func (tc *TargetConfig) BufferSizeString() string

+ func (tc *TargetConfig) InsecureString() string

+ func (tc *TargetConfig) OutputsString() string

+ func (tc *TargetConfig) PasswordString() string

+ func (tc *TargetConfig) SkipVerifyString() 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

Nov 5, 2020

Changes in this version

type Collector

+ func (c *Collector) Export(ctx context.Context, rsp *gnmi.SubscribeResponse, m outputs.Meta, ...)

Oct 21, 2020

Changes in this version

+ type CollectorOption func(c *Collector)

+ func WithDialOptions(dialOptions []grpc.DialOption) CollectorOption

+ func WithLogger(logger *log.Logger) CollectorOption

+ func WithOutputs(outs map[string][]outputs.Output) CollectorOption

+ func WithSubscriptions(subs map[string]*SubscriptionConfig) CollectorOption

Sep 18, 2020

Changes in this version

type Config

+ RetryTimer time.Duration

type TargetConfig

+ RetryTimer time.Duration

+ type TargetError struct

+ Err error

+ SubscriptionName string

Aug 7, 2020

Changes in this version

+ func TagsFromGNMIPath(p *gnmi.Path) (string, map[string]string)

+ type EventMsg struct

+ Deletes []string

+ Name string

+ Tags map[string]string

+ Timestamp int64

+ Values map[string]interface{}

+ func ResponseToEventMsgs(name string, rsp *gnmi.SubscribeResponse, meta map[string]string) ([]*EventMsg, error)

+ type MarshalOptions struct

+ Format string

+ Indent string

+ Multiline bool

+ func (o *MarshalOptions) FormatJSON(m proto.Message, meta map[string]string) ([]byte, error)

+ func (o *MarshalOptions) Marshal(msg proto.Message, meta map[string]string) ([]byte, error)

+ type NotificationRspMsg struct

+ Deletes []string

+ Meta map[string]interface{}

+ Prefix string

+ Source string

+ SubscriptionName string

+ SystemName string

+ Target string

+ Time *time.Time

+ Timestamp int64

+ Updates []update

Jul 16, 2020

Changes in this version

+ func CreatePrefix(prefix, target string) (*gnmi.Path, error)

+ func ParsePath(p string) (*gnmi.Path, error)

+ type Collector struct

+ Config *Config

+ DialOpts []grpc.DialOption

+ Logger *log.Logger

+ Outputs map[string][]outputs.Output

+ Subscriptions map[string]*SubscriptionConfig

+ Targets map[string]*Target

+ func NewCollector(ctx context.Context, config *Config, targetConfigs map[string]*TargetConfig, ...) *Collector

+ func (c *Collector) FormatMsg(meta map[string]interface{}, rsp *gnmi.SubscribeResponse) ([]byte, error)

+ func (c *Collector) InitTarget(tc *TargetConfig)

+ func (c *Collector) PolledSubscriptionsTargets() map[string][]string

+ func (c *Collector) Start()

+ func (c *Collector) Subscribe(tName string) error

+ func (c *Collector) TargetPoll(targetName, subscriptionName string) (*gnmi.SubscribeResponse, error)

+ type Config struct

+ Debug bool

+ Format string

+ PrometheusAddress string

+ TargetReceiveBuffer uint

+ type SubscribeResponse struct

+ Response *gnmi.SubscribeResponse

+ SubscriptionName string

+ type SubscriptionConfig struct

+ Encoding string

+ HeartbeatInterval *time.Duration

+ Mode string

+ Models []string

+ Name string

+ Paths []string

+ Prefix string

+ Qos *uint32

+ SampleInterval *time.Duration

+ StreamMode string

+ SuppressRedundant bool

+ Target string

+ UpdatesOnly bool

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

+ func (sc *SubscriptionConfig) String() string

+ type Target struct

+ Client gnmi.GNMIClient

+ Config *TargetConfig

+ Errors chan error

+ Outputs []outputs.Output

+ PollChan chan string

+ SubscribeClients map[string]gnmi.GNMI_SubscribeClient

+ SubscribeResponses chan *SubscribeResponse

+ Subscriptions []*SubscriptionConfig

+ func NewTarget(c *TargetConfig) *Target

+ func (t *Target) Capabilities(ctx context.Context, ext ...*gnmi_ext.Extension) (*gnmi.CapabilityResponse, error)

+ func (t *Target) CreateGNMIClient(ctx context.Context, opts ...grpc.DialOption) error

+ func (t *Target) Export(msg []byte, m outputs.Meta)

+ func (t *Target) Get(ctx context.Context, req *gnmi.GetRequest) (*gnmi.GetResponse, error)

+ func (t *Target) Set(ctx context.Context, req *gnmi.SetRequest) (*gnmi.SetResponse, error)

+ func (t *Target) Subscribe(ctx context.Context, req *gnmi.SubscribeRequest, subscriptionName string)

+ type TargetConfig struct

+ Address string

+ BufferSize uint

+ Insecure *bool

+ Name string

+ Outputs []string

+ Password *string

+ SkipVerify *bool

+ Subscriptions []string

+ TLSCA *string

+ TLSCert *string

+ TLSKey *string

+ Timeout time.Duration

+ Username *string

+ func (tc *TargetConfig) String() string