Help us shape the future of Go! Take the 2026 Go Developer Survey

gnmi

package
v0.0.73 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2026 License: Apache-2.0 Imports: 30 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 utils.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, sendTimeout time.Duration) *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