utils

Sep 16, 2026

Changes in this version

+ func RecoverMiddleware(logger func() *slog.Logger) mux.MiddlewareFunc

+ func SubscriptionConfigToNotification(sub *types.SubscriptionConfig, e gnmi.Encoding) *gnmi.Notification

+ func TargetConfigToNotification(tc *types.TargetConfig, e gnmi.Encoding) *gnmi.Notification

Sep 9, 2026

Changes in this version

+ func ValidateSubscriptionConfig(sc *types.SubscriptionConfig) error

May 14, 2026

Changes in this version

+ func SetSaramaLoggerOnce(logger *slog.Logger, level slog.Level)

Feb 17, 2026

Changes in this version

+ type RegisteredExtensions map[int32]string

+ func ParseRegisteredExtensions(pairs []string) (RegisteredExtensions, error)

Feb 1, 2026

Changes in this version

+ func GetConfigMaps(s store.Store[any]) (map[string]*types.TargetConfig, map[string]map[string]any, ...)

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)