rpc

Documentation

Index

• type DataServer
  • func NewDataServer(address string, s *replica.Server) *DataServer
  • func (s *DataServer) ListenAndServe() error
• type ReplicaHealthCheckServer
  • func NewReplicaHealthCheckServer(rs *ReplicaServer) *ReplicaHealthCheckServer
  • func (hc *ReplicaHealthCheckServer) Check(context.Context, *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
  • func (hc *ReplicaHealthCheckServer) Watch(req *healthpb.HealthCheckRequest, ws healthpb.Health_WatchServer) error
• type ReplicaServer
  • func NewReplicaServer(s *replica.Server) *ReplicaServer
  • func (rs *ReplicaServer) DiskMarkAsRemoved(ctx context.Context, req *ptypes.DiskMarkAsRemovedRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) DiskPrepareRemove(ctx context.Context, req *ptypes.DiskPrepareRemoveRequest) (*ptypes.DiskPrepareRemoveReply, error)
  • func (rs *ReplicaServer) DiskRemove(ctx context.Context, req *ptypes.DiskRemoveRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) DiskReplace(ctx context.Context, req *ptypes.DiskReplaceRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) RebuildingSet(ctx context.Context, req *ptypes.RebuildingSetRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaClose(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaCreate(ctx context.Context, req *ptypes.ReplicaCreateRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaDelete(ctx context.Context, req *empty.Empty) (*empty.Empty, error)
  • func (rs *ReplicaServer) ReplicaExpand(ctx context.Context, req *ptypes.ReplicaExpandRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaGet(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaOpen(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaReload(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaRevert(ctx context.Context, req *ptypes.ReplicaRevertRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) ReplicaSnapshot(ctx context.Context, req *ptypes.ReplicaSnapshotRequest) (*ptypes.Replica, error)
  • func (rs *ReplicaServer) RevisionCounterSet(ctx context.Context, req *ptypes.RevisionCounterSetRequest) (*ptypes.Replica, error)

Types

type DataServer

type DataServer struct {
	// contains filtered or unexported fields
}

func NewDataServer

func NewDataServer(address string, s *replica.Server) *DataServer

func (*DataServer) ListenAndServe

func (s *DataServer) ListenAndServe() error

type ReplicaHealthCheckServer

type ReplicaHealthCheckServer struct {
	// contains filtered or unexported fields
}

func NewReplicaHealthCheckServer

func NewReplicaHealthCheckServer(rs *ReplicaServer) *ReplicaHealthCheckServer

func (*ReplicaHealthCheckServer) Check

func (hc *ReplicaHealthCheckServer) Check(context.Context, *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

func (*ReplicaHealthCheckServer) Watch

func (hc *ReplicaHealthCheckServer) Watch(req *healthpb.HealthCheckRequest, ws healthpb.Health_WatchServer) error

type ReplicaServer

type ReplicaServer struct {
	// contains filtered or unexported fields
}

func NewReplicaServer

func NewReplicaServer(s *replica.Server) *ReplicaServer

func (*ReplicaServer) DiskMarkAsRemoved

func (rs *ReplicaServer) DiskMarkAsRemoved(ctx context.Context, req *ptypes.DiskMarkAsRemovedRequest) (*ptypes.Replica, error)

func (*ReplicaServer) DiskPrepareRemove

func (rs *ReplicaServer) DiskPrepareRemove(ctx context.Context, req *ptypes.DiskPrepareRemoveRequest) (*ptypes.DiskPrepareRemoveReply, error)

func (*ReplicaServer) DiskRemove

func (rs *ReplicaServer) DiskRemove(ctx context.Context, req *ptypes.DiskRemoveRequest) (*ptypes.Replica, error)

func (*ReplicaServer) DiskReplace

func (rs *ReplicaServer) DiskReplace(ctx context.Context, req *ptypes.DiskReplaceRequest) (*ptypes.Replica, error)

func (*ReplicaServer) RebuildingSet

func (rs *ReplicaServer) RebuildingSet(ctx context.Context, req *ptypes.RebuildingSetRequest) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaClose

func (rs *ReplicaServer) ReplicaClose(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaCreate

func (rs *ReplicaServer) ReplicaCreate(ctx context.Context, req *ptypes.ReplicaCreateRequest) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaDelete

func (rs *ReplicaServer) ReplicaDelete(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*ReplicaServer) ReplicaExpand

func (rs *ReplicaServer) ReplicaExpand(ctx context.Context, req *ptypes.ReplicaExpandRequest) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaGet

func (rs *ReplicaServer) ReplicaGet(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaOpen

func (rs *ReplicaServer) ReplicaOpen(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaReload

func (rs *ReplicaServer) ReplicaReload(ctx context.Context, req *empty.Empty) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaRevert

func (rs *ReplicaServer) ReplicaRevert(ctx context.Context, req *ptypes.ReplicaRevertRequest) (*ptypes.Replica, error)

func (*ReplicaServer) ReplicaSnapshot

func (rs *ReplicaServer) ReplicaSnapshot(ctx context.Context, req *ptypes.ReplicaSnapshotRequest) (*ptypes.Replica, error)

func (*ReplicaServer) RevisionCounterSet

func (rs *ReplicaServer) RevisionCounterSet(ctx context.Context, req *ptypes.RevisionCounterSetRequest) (*ptypes.Replica, error)