utils

Oct 20, 2025

Changes in this version

+ const SubscriptionMode_ONCE

+ const SubscriptionMode_POLL

+ const SubscriptionMode_STREAM

+ const SubscriptionStreamMode_ON_CHANGE

+ const SubscriptionStreamMode_SAMPLE

+ const SubscriptionStreamMode_TARGET_DEFINED

+ var ErrConfig = errors.New("config error")

+ func CreateSubscribeRequest(cfg *types.SubscriptionConfig, tc *types.TargetConfig, defaultEncoding string) (*gnmi.SubscribeRequest, error)

+ func SubscriptionOpts(sc *types.SubscriptionConfig, tc *types.TargetConfig, defaultEncoding string) ([]api.GNMIOption, error)

May 13, 2024

Changes in this version

+ func NewTokenProvider(clientID, clientSecret, tokenURL string) sarama.AccessTokenProvider

+ type TokenProvider struct

+ func (t *TokenProvider) Token() (*sarama.AccessToken, error)