Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTarget ¶
func NewTarget(ctx context.Context, name string, cfg *config.SBI, runningStore targetTypes.RunningStore, schemaClient dsutils.SchemaClientBound, taskpoolFactory pool.VirtualPoolFactory, opts ...grpc.DialOption) (*gnmiTarget, error)
Types ¶
type GetSync ¶
type GetSync struct {
// contains filtered or unexported fields
}
func NewGetSync ¶
func NewGetSync(ctx context.Context, target GetTarget, c *config.SyncProtocol, runningStore types.RunningStore, schemaClient dsutils.SchemaClientBound) (*GetSync, error)
type GetTarget ¶
type GetTarget interface {
Get(ctx context.Context, req *sdcpb.GetDataRequest) (*sdcpb.GetDataResponse, error)
}
type NotificationData ¶
type NotificationData struct {
// contains filtered or unexported fields
}
type NotificationProcessorTaskParameters ¶
type NotificationProcessorTaskParameters struct {
// contains filtered or unexported fields
}
func NewNotificationProcessorTaskParameters ¶
func NewNotificationProcessorTaskParameters(notificationResult chan<- *NotificationData, scb dsutils.SchemaClientBound) *NotificationProcessorTaskParameters
type OnceSync ¶
type OnceSync struct {
// contains filtered or unexported fields
}
func NewOnceSync ¶
func NewOnceSync(ctx context.Context, target SyncTarget, c *config.SyncProtocol, runningStore types.RunningStore, vpoolFactory pool.VirtualPoolFactory) *OnceSync
type StreamSync ¶
type StreamSync struct {
// contains filtered or unexported fields
}
func NewStreamSync ¶
func NewStreamSync(ctx context.Context, target SyncTarget, c *config.SyncProtocol, runningStore types.RunningStore, schemaClient dsutils.SchemaClientBound, vpoolFactory pool.VirtualPoolFactory) *StreamSync
func (*StreamSync) Name ¶
func (s *StreamSync) Name() string
func (*StreamSync) Start ¶
func (s *StreamSync) Start() error
func (*StreamSync) Stop ¶
func (s *StreamSync) Stop() error
type SyncTarget ¶
type SyncTarget interface {
Subscribe(ctx context.Context, req *gnmi.SubscribeRequest, subscriptionName string) (chan *gnmi.SubscribeResponse, chan error)
}
Click to show internal directories.
Click to hide internal directories.