Documentation
¶
Index ¶
- Constants
- Variables
- func CreateSubscribeRequest(cfg *types.SubscriptionConfig, tc *types.TargetConfig, defaultEncoding string) (*gnmi.SubscribeRequest, error)
- func NewTokenProvider(clientID, clientSecret, tokenURL string) sarama.AccessTokenProvider
- func SubscriptionOpts(sc *types.SubscriptionConfig, tc *types.TargetConfig, defaultEncoding string) ([]api.GNMIOption, error)
- type TokenProvider
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 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 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
Click to show internal directories.
Click to hide internal directories.