grpcsync

Aug 24, 2018

Changes in this version

+ var DefaultPlugin = *NewPlugin()

+ type Option func(*Plugin)

+ func UseDeps(cb func(*Deps)) Option

type Plugin

+ func NewPlugin(opts ...Option) *Plugin

Sep 26, 2017

Changes in this version

+ type Deps struct

+ GRPC grpc.Server

Aug 28, 2017

Changes in this version

+ type Adapter struct

+ func NewAdapter() *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 Plugin struct

+ Adapter datasync.KeyValProtoWatcher

+ ServiceLabel servicelabel.ReaderAPI

+ func (plugin *Plugin) Close() error

+ func (plugin *Plugin) Init() error