replica

type ReplicationClient interface {
	// During gossip, the initiating replica sends a randomly selected remote peer the
	// version vectors of all objects it currently stores. The remote peer should
	// respond with updates that correspond to more recent versions of the objects. The
	// remote peer can than also make a reciprocal request for updates by sending the
	// set of versions requested that were more recent on the initiating replica, and
	// use a partial flag to indicate that it is requesting specific versions. This
	// mechanism implements bilateral anti-entropy: a push and pull gossip.
	Gossip(ctx context.Context, in *VersionVectors, opts ...grpc.CallOption) (*Updates, error)
}

type ReplicationServer interface {
	// During gossip, the initiating replica sends a randomly selected remote peer the
	// version vectors of all objects it currently stores. The remote peer should
	// respond with updates that correspond to more recent versions of the objects. The
	// remote peer can than also make a reciprocal request for updates by sending the
	// set of versions requested that were more recent on the initiating replica, and
	// use a partial flag to indicate that it is requesting specific versions. This
	// mechanism implements bilateral anti-entropy: a push and pull gossip.
	Gossip(context.Context, *VersionVectors) (*Updates, error)
	// contains filtered or unexported methods
}

type UnimplementedReplicationServer struct {
}

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

type Updates struct {
	Objects []*object.Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

type VersionVectors struct {

	// Version vectors of objects without data.
	Objects []*object.Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// A request to consider only the objects specified in the version vector and not
	// the entire namespace (e.g. ignore objects that are not specified).
	Partial bool `protobuf:"varint,2,opt,name=partial,proto3" json:"partial,omitempty"`
	// Limit the comparison only to the specified namespace(s). If not set or empty,
	// then all namespaces are considered.
	Namespaces []string `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}