replica

type ReplicationClient interface {
	// Gossip implements biltateral anti-entropy: during a Gossip session the initiating
	// replica pushes updates to the remote peer and pulls requested changes. Using
	// bidirectional streaming, the initiating peer sends data-less sync messages with
	// the versions of objects it stores locally. The remote replica then responds with
	// data if its local version is later or sends a sync message back requesting the
	// data from the initating replica if its local version is earlier (no exchange)
	// occurs if both replicas have the same version. At the end of a gossip session,
	// both replicas should have synchronized and have identical underlying data stores.
	Gossip(ctx context.Context, opts ...grpc.CallOption) (Replication_GossipClient, error)
}

type ReplicationServer interface {
	// Gossip implements biltateral anti-entropy: during a Gossip session the initiating
	// replica pushes updates to the remote peer and pulls requested changes. Using
	// bidirectional streaming, the initiating peer sends data-less sync messages with
	// the versions of objects it stores locally. The remote replica then responds with
	// data if its local version is later or sends a sync message back requesting the
	// data from the initating replica if its local version is earlier (no exchange)
	// occurs if both replicas have the same version. At the end of a gossip session,
	// both replicas should have synchronized and have identical underlying data stores.
	Gossip(Replication_GossipServer) error
	// contains filtered or unexported methods
}

type Replication_GossipClient interface {
	Send(*Sync) error
	Recv() (*Sync, error)
	grpc.ClientStream
}

type Replication_GossipServer interface {
	Send(*Sync) error
	Recv() (*Sync, error)
	grpc.ServerStream
}

type Sync struct {
	Status Sync_Status    `protobuf:"varint,1,opt,name=status,proto3,enum=honu.replica.v1.Sync_Status" json:"status,omitempty"` // The status/type of sync messages
	Object *object.Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`                                   // The object being synchronized
	Error  string         `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`                                     // Error information if the object failed to sync
	// contains filtered or unexported fields
}

type Sync_Status int32

type UnimplementedReplicationServer struct {
}

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