proto

type InternalReplClient interface {
	SyncNodes(ctx context.Context, in *SyncNodesRequest, opts ...grpc.CallOption) (*SyncNodesResponse, error)
}

type InternalReplServer interface {
	SyncNodes(context.Context, *SyncNodesRequest) (*SyncNodesResponse, error)
	// contains filtered or unexported methods
}

type Node struct {
	Path      string               `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Version   int64                `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Deleted   bool                 `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	Data      []byte               `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"` //string origin = 6;
	// contains filtered or unexported fields
}

type NodeMeta struct {
	Path    string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Version int64  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type NodeStateSummary struct {
	NodeMeta []*NodeMeta `protobuf:"bytes,1,rep,name=node_meta,json=nodeMeta,proto3" json:"node_meta,omitempty"`
	// contains filtered or unexported fields
}

type RepldsClient interface {
	// Store one or more nodes on the database.
	Store(ctx context.Context, in *StoreRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Watch allows for incremental asynchronous replication of parts of
	// the tree (watchers). Since there is no global state, the sync +
	// update algorithm only works within a single streaming connection.
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Replds_WatchClient, error)
}

type RepldsServer interface {
	// Store one or more nodes on the database.
	Store(context.Context, *StoreRequest) (*empty.Empty, error)
	// Watch allows for incremental asynchronous replication of parts of
	// the tree (watchers). Since there is no global state, the sync +
	// update algorithm only works within a single streaming connection.
	Watch(*WatchRequest, Replds_WatchServer) error
	// contains filtered or unexported methods
}

type Replds_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type Replds_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type StoreRequest struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

type SyncNodesRequest struct {
	Summary *NodeStateSummary `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

type SyncNodesResponse struct {
	Nodes   []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Partial bool    `protobuf:"varint,2,opt,name=partial,proto3" json:"partial,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedInternalReplServer struct {
}

type UnimplementedRepldsServer struct {
}

type UnsafeInternalReplServer interface {
	// contains filtered or unexported methods
}

type UnsafeRepldsServer interface {
	// contains filtered or unexported methods
}

type WatchRequest struct {
	BasePath string            `protobuf:"bytes,1,opt,name=base_path,json=basePath,proto3" json:"base_path,omitempty"`
	Summary  *NodeStateSummary `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

type WatchResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}