Skip to content
Snippets Groups Projects

Resolve "Add an option to send gNMI Subscribe requests via SBI"

5 files
+ 67
58
Compare changes
  • Side-by-side
  • Inline
Files
5
@@ -15,12 +15,12 @@ type Transport interface {
@@ -15,12 +15,12 @@ type Transport interface {
Get(ctx context.Context, params ...string) (interface{}, error)
Get(ctx context.Context, params ...string) (interface{}, error)
Set(ctx context.Context, payload change.Payload, path string, schema *ytypes.Schema) error
Set(ctx context.Context, payload change.Payload, path string, schema *ytypes.Schema) error
Subscribe(ctx context.Context, params ...string) error
Subscribe(ctx context.Context, params ...string) error
SubscribeInternal(ctx context.Context, subscribeCallbackFunc HandleSubscribeResponse) error
SubscribeInternal(ctx context.Context, subscribeCallbackFunc HandleSubscribeResponse, pndID, deviceID, deviceName string) error
Type() string
Type() string
ProcessResponse(resp interface{}, root interface{}, models *ytypes.Schema) error
ProcessResponse(resp interface{}, root interface{}, models *ytypes.Schema) error
}
}
type (
type (
// HandleSubscribeResponse is the callback function to handle subcription responses
// HandleSubscribeResponse is the callback function to handle subcription responses
HandleSubscribeResponse func(*gpb.SubscribeResponse)
HandleSubscribeResponse func(*gpb.SubscribeResponse, string, string, string)
)
)
Loading