gnmi

package
v0.0.67 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 16, 2026 License: Apache-2.0 Imports: 28 Imported by: 0

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)

func (*GetSync) Name

func (s *GetSync) Name() string

func (*GetSync) Start

func (s *GetSync) Start() error

func (*GetSync) Stop

func (s *GetSync) Stop() error

type GetTarget

type GetTarget interface {
	Get(ctx context.Context, req *sdcpb.GetDataRequest) (*sdcpb.GetDataResponse, error)
}

type GnmiSync

type GnmiSync interface {
	Start() error
	Stop() error
	Name() string
}

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

func (*OnceSync) Name

func (s *OnceSync) Name() string

func (*OnceSync) Start

func (s *OnceSync) Start() error

func (*OnceSync) Stop

func (s *OnceSync) Stop() error

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)
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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