api

package module

Go to main page

Versions in this module

v0

v0.1.9

Feb 3, 2025

v0.1.8

Jul 9, 2024

Changes in this version

+ func Extension_CommitCancel(id string) func(msg proto.Message) error

+ func Extension_CommitConfirm(id string) func(msg proto.Message) error

+ func Extension_CommitRequest(id string, dur time.Duration) func(msg proto.Message) error

+ func Extension_CommitSetRollbackDuration(id string, dur time.Duration) func(msg proto.Message) error

+ func Extension_Depth(lvl uint32) func(msg proto.Message) error

v0.1.7

May 6, 2024

v0.1.6

Apr 25, 2024

Changes in this version

type TargetOption

+ func TLSConfig(tlsconfig *tls.Config) TargetOption

v0.1.5

Mar 5, 2024

v0.1.4

Mar 4, 2024

v0.1.3

Feb 13, 2024

v0.1.2

Jan 21, 2024

v0.1.1

Nov 13, 2023

v0.1.0

Nov 12, 2023

Changes in this version

+ const DefaultGNMIVersion

+ var DefaultTargetTimeout = 10 * time.Second

+ var ErrInvalidMsgType = errors.New("invalid message type")

+ var ErrInvalidValue = errors.New("invalid value")

+ func Accept(b bool) func(msg proto.Message) error

+ func AllowAggregation(b bool) func(msg proto.Message) error

+ func Atomic(b bool) func(msg proto.Message) error

+ func Close(b bool) func(msg proto.Message) error

+ func Data(d []byte) func(msg proto.Message) error

+ func DataType(datat string) func(msg proto.Message) error

+ func DataTypeALL() func(msg proto.Message) error

+ func DataTypeCONFIG() func(msg proto.Message) error

+ func DataTypeOPERATIONAL() func(msg proto.Message) error

+ func DataTypeSTATE() func(msg proto.Message) error

+ func Delete(p string) func(msg proto.Message) error

+ func Encoding(encoding string) func(msg proto.Message) error

+ func EncodingASCII() func(msg proto.Message) error

+ func EncodingBYTES() func(msg proto.Message) error

+ func EncodingCustom(enc int) func(msg proto.Message) error

+ func EncodingJSON() func(msg proto.Message) error

+ func EncodingJSON_IETF() func(msg proto.Message) error

+ func EncodingPROTO() func(msg proto.Message) error

+ func Error(e string) func(msg proto.Message) error

+ func Extension(ext *gnmi_ext.Extension) func(msg proto.Message) error

+ func Extension_HistoryRange(start, end time.Time) func(msg proto.Message) error

+ func Extension_HistorySnapshotTime(tm time.Time) func(msg proto.Message) error

+ func HeartbeatInterval(d time.Duration) func(msg proto.Message) error

+ func NewCapabilitiesRequest(opts ...GNMIOption) (*gnmi.CapabilityRequest, error)

+ func NewCapabilitiesResponse(opts ...GNMIOption) (*gnmi.CapabilityResponse, error)

+ func NewData(opts ...TunnelOption) (*tpb.Data, error)

+ func NewGetRequest(opts ...GNMIOption) (*gnmi.GetRequest, error)

+ func NewGetResponse(opts ...GNMIOption) (*gnmi.GetResponse, error)

+ func NewRegisterOpSession(opts ...TunnelOption) (*tpb.RegisterOp, error)

+ func NewRegisterOpSubscription(opts ...TunnelOption) (*tpb.RegisterOp, error)

+ func NewRegisterOpTarget(opts ...TunnelOption) (*tpb.RegisterOp, error)

+ func NewSetRequest(opts ...GNMIOption) (*gnmi.SetRequest, error)

+ func NewSetResponse(opts ...GNMIOption) (*gnmi.SetResponse, error)

+ func NewSubscribePollRequest(opts ...GNMIOption) (*gnmi.SubscribeRequest, error)

+ func NewSubscribeRequest(opts ...GNMIOption) (*gnmi.SubscribeRequest, error)

+ func NewSubscribeResponse(opts ...GNMIOption) (*gnmi.SubscribeResponse, error)

+ func NewSubscribeSyncResponse(opts ...GNMIOption) (*gnmi.SubscribeResponse, error)

+ func NewTarget(opts ...TargetOption) (*target.Target, error)

+ func Notification(opts ...GNMIOption) func(msg proto.Message) error

+ func Operation(oper string) func(msg proto.Message) error

+ func OperationDELETE() func(msg proto.Message) error

+ func OperationINVALID() func(msg proto.Message) error

+ func OperationREPLACE() func(msg proto.Message) error

+ func OperationUPDATE() func(msg proto.Message) error

+ func Path(p string) func(msg proto.Message) error

+ func Prefix(prefix string) func(msg proto.Message) error

+ func Qos(qos uint32) func(msg proto.Message) error

+ func Replace(opts ...GNMIOption) func(msg proto.Message) error

+ func SampleInterval(d time.Duration) func(msg proto.Message) error

+ func Subscription(opts ...GNMIOption) func(msg proto.Message) error

+ func SubscriptionListMode(mode string) func(msg proto.Message) error

+ func SubscriptionListModeONCE() func(msg proto.Message) error

+ func SubscriptionListModePOLL() func(msg proto.Message) error

+ func SubscriptionListModeSTREAM() func(msg proto.Message) error

+ func SubscriptionMode(mode string) func(msg proto.Message) error

+ func SubscriptionModeON_CHANGE() func(msg proto.Message) error

+ func SubscriptionModeSAMPLE() func(msg proto.Message) error

+ func SubscriptionModeTARGET_DEFINED() func(msg proto.Message) error

+ func SubscriptionOpSubscribe() func(msg proto.Message) error

+ func SubscriptionOpUnsubscribe() func(msg proto.Message) error

+ func SupportedEncoding(encodings ...string) func(msg proto.Message) error

+ func SupportedModel(name, org, version string) func(msg proto.Message) error

+ func SuppressRedundant(s bool) func(msg proto.Message) error

+ func Tag(t int32) func(msg proto.Message) error

+ func Target(target string) func(msg proto.Message) error

+ func TargetName(n string) func(msg proto.Message) error

+ func TargetOpAdd() func(msg proto.Message) error

+ func TargetOpRemove() func(msg proto.Message) error

+ func TargetType(typ string) func(msg proto.Message) error

+ func Timestamp(t int64) func(msg proto.Message) error

+ func TimestampNow() func(msg proto.Message) error

+ func TunnelSession(opts ...TunnelOption) func(msg proto.Message) error

+ func TunnelSubscription(opts ...TunnelOption) func(msg proto.Message) error

+ func TunnelTarget(opts ...TunnelOption) func(msg proto.Message) error

+ func UnionReplace(opts ...GNMIOption) func(msg proto.Message) error

+ func Update(opts ...GNMIOption) func(msg proto.Message) error

+ func UpdateResult(opts ...GNMIOption) func(msg proto.Message) error

+ func UpdatesOnly(b bool) func(msg proto.Message) error

+ func UseModel(name, org, version string) func(msg proto.Message) error

+ func Value(data interface{}, encoding string) func(msg proto.Message) error

+ func Version(v string) func(msg proto.Message) error

+ type GNMIOption func(proto.Message) error

+ type TargetOption func(*target.Target) error

+ func Address(addr string) TargetOption

+ func Gzip(b bool) TargetOption

+ func Insecure(i bool) TargetOption

+ func LogTLSSecret(b bool) TargetOption

+ func Name(name string) TargetOption

+ func Password(password string) TargetOption

+ func SkipVerify(i bool) TargetOption

+ func TLSCA(tlsca string) TargetOption

+ func TLSCert(cert string) TargetOption

+ func TLSKey(key string) TargetOption

+ func TLSMaxVersion(v string) TargetOption

+ func TLSMinVersion(v string) TargetOption

+ func TLSVersion(v string) TargetOption

+ func Timeout(timeout time.Duration) TargetOption

+ func Token(token string) TargetOption

+ func Username(username string) TargetOption

+ type TunnelOption func(proto.Message) error

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