rpc

Documentation

Index

• func NewReplicaServer(volumeName, instanceName string, s *replica.Server) *grpc.Server
• type DataServer
  • func NewDataServer(protocol types.DataServerProtocol, 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 (rs *ReplicaServer) DiskMarkAsRemoved(ctx context.Context, req *ptypes.DiskMarkAsRemovedRequest) (*ptypes.DiskMarkAsRemovedResponse, error)
  • func (rs *ReplicaServer) DiskPrepareRemove(ctx context.Context, req *ptypes.DiskPrepareRemoveRequest) (*ptypes.DiskPrepareRemoveResponse, error)
  • func (rs *ReplicaServer) DiskRemove(ctx context.Context, req *ptypes.DiskRemoveRequest) (*ptypes.DiskRemoveResponse, error)
  • func (rs *ReplicaServer) DiskReplace(ctx context.Context, req *ptypes.DiskReplaceRequest) (*ptypes.DiskReplaceResponse, error)
  • func (rs *ReplicaServer) RebuildingSet(ctx context.Context, req *ptypes.RebuildingSetRequest) (*ptypes.RebuildingSetResponse, error)
  • func (rs *ReplicaServer) ReplicaClose(ctx context.Context, req *empty.Empty) (*ptypes.ReplicaCloseResponse, error)
  • func (rs *ReplicaServer) ReplicaCreate(ctx context.Context, req *ptypes.ReplicaCreateRequest) (*ptypes.ReplicaCreateResponse, 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.ReplicaExpandResponse, error)
  • func (rs *ReplicaServer) ReplicaGet(ctx context.Context, req *empty.Empty) (*ptypes.ReplicaGetResponse, error)
  • func (rs *ReplicaServer) ReplicaOpen(ctx context.Context, req *empty.Empty) (*ptypes.ReplicaOpenResponse, error)
  • func (rs *ReplicaServer) ReplicaReload(ctx context.Context, req *empty.Empty) (*ptypes.ReplicaReloadResponse, error)
  • func (rs *ReplicaServer) ReplicaRevert(ctx context.Context, req *ptypes.ReplicaRevertRequest) (*ptypes.ReplicaRevertResponse, error)
  • func (rs *ReplicaServer) ReplicaSnapshot(ctx context.Context, req *ptypes.ReplicaSnapshotRequest) (*ptypes.ReplicaSnapshotResponse, error)
  • func (rs *ReplicaServer) RevisionCounterSet(ctx context.Context, req *ptypes.RevisionCounterSetRequest) (*ptypes.RevisionCounterSetResponse, error)
  • func (rs *ReplicaServer) UnmapMarkDiskChainRemovedSet(ctx context.Context, req *ptypes.UnmapMarkDiskChainRemovedSetRequest) (*ptypes.UnmapMarkDiskChainRemovedSetResponse, error)

Functions

func NewReplicaServer

func NewReplicaServer(volumeName, instanceName string, s *replica.Server) *grpc.Server

Types

type DataServer

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

func NewDataServer

func NewDataServer(protocol types.DataServerProtocol, 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 (*ReplicaServer) DiskMarkAsRemoved

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

func (*ReplicaServer) DiskPrepareRemove

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

func (*ReplicaServer) DiskRemove

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

func (*ReplicaServer) DiskReplace

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

func (*ReplicaServer) RebuildingSet

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

func (*ReplicaServer) ReplicaClose

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

func (*ReplicaServer) ReplicaCreate

func (rs *ReplicaServer) ReplicaCreate(ctx context.Context, req *ptypes.ReplicaCreateRequest) (*ptypes.ReplicaCreateResponse, 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.ReplicaExpandResponse, error)

func (*ReplicaServer) ReplicaGet

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

func (*ReplicaServer) ReplicaOpen

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

func (*ReplicaServer) ReplicaReload

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

func (*ReplicaServer) ReplicaRevert

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

func (*ReplicaServer) ReplicaSnapshot

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

func (*ReplicaServer) RevisionCounterSet

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

func (*ReplicaServer) UnmapMarkDiskChainRemovedSet

func (rs *ReplicaServer) UnmapMarkDiskChainRemovedSet(ctx context.Context, req *ptypes.UnmapMarkDiskChainRemovedSetRequest) (*ptypes.UnmapMarkDiskChainRemovedSetResponse, error)