utils

package

v0.44.1 Latest Latest Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 13 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/openconfig/gnmic

Links

Documentation ¶

Index ¶

Constants
Variables
func CreateSubscribeRequest(cfg *types.SubscriptionConfig, tc *types.TargetConfig, defaultEncoding string) (*gnmi.SubscribeRequest, error)
func GetConfigMaps(s store.Store[any]) (map[string]*types.TargetConfig, map[string]map[string]any, ...)
func NewTokenProvider(clientID, clientSecret, tokenURL string) sarama.AccessTokenProvider
func SubscriptionOpts(sc *types.SubscriptionConfig, tc *types.TargetConfig, defaultEncoding string) ([]api.GNMIOption, error)
type RegisteredExtensions
- func ParseRegisteredExtensions(pairs []string) (RegisteredExtensions, error)
type TokenProvider
- func (t *TokenProvider) Token() (*sarama.AccessToken, error)

Constants ¶

View Source

const (
	SubscriptionMode_STREAM               = "STREAM"
	SubscriptionMode_ONCE                 = "ONCE"
	SubscriptionMode_POLL                 = "POLL"
	SubscriptionStreamMode_TARGET_DEFINED = "TARGET_DEFINED"
	SubscriptionStreamMode_ON_CHANGE      = "ON_CHANGE"
	SubscriptionStreamMode_SAMPLE         = "SAMPLE"
)

Variables ¶

View Source

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

Functions ¶

func CreateSubscribeRequest ¶ added in v0.42.1

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

func GetConfigMaps ¶ added in v0.43.0

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

func NewTokenProvider ¶

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

func SubscriptionOpts ¶ added in v0.42.1

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

Types ¶

type RegisteredExtensions ¶ added in v0.44.0

type RegisteredExtensions map[int32]string

func ParseRegisteredExtensions ¶ added in v0.44.0

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

type TokenProvider ¶

type TokenProvider struct {
	// contains filtered or unexported fields
}

TokenProvider is a simple struct that implements sarama.AccessTokenProvider.

func (*TokenProvider) Token ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL