Versions in this module Expand all Collapse all v2 v2.5.0 Jan 15, 2020 Changes in this version + var DefaultPlugin = *NewPlugin() + type Adapter struct + func NewAdapter(grpcServer *grpc.Server) *Adapter + func (adapter *Adapter) Close() error + func (adapter *Adapter) Watch(resyncName string, changeChan chan datasync.ChangeEvent, ...) (datasync.WatchRegistration, error) + type DataMsgServiceServer struct + func NewDataMsgServiceServer(adapter *Adapter) *DataMsgServiceServer + func (s *DataMsgServiceServer) DataChanges(stream msg.DataMsgService_DataChangesServer) error + func (s *DataMsgServiceServer) DataResyncs(ctx context.Context, req *msg.DataResyncRequests) (*msg.DataResyncReplies, error) + func (s *DataMsgServiceServer) Ping(ctx context.Context, req *msg.PingRequest) (*msg.PingReply, error) + type Deps struct + GRPC grpc.Server + type Option func(*Plugin) + func UseDeps(cb func(*Deps)) Option + type Plugin struct + Adapter datasync.KeyValProtoWatcher + func NewPlugin(opts ...Option) *Plugin + func (p *Plugin) Close() error + func (p *Plugin) Init() error v2.5.0-alpha Dec 13, 2019 Other modules containing this package go.ligato.io/cn-infra
Go to main page