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 *enginerpc.DiskMarkAsRemovedRequest) (*enginerpc.DiskMarkAsRemovedResponse, error)
  • func (rs *ReplicaServer) DiskPrepareRemove(ctx context.Context, req *enginerpc.DiskPrepareRemoveRequest) (*enginerpc.DiskPrepareRemoveResponse, error)
  • func (rs *ReplicaServer) DiskRemove(ctx context.Context, req *enginerpc.DiskRemoveRequest) (*enginerpc.DiskRemoveResponse, error)
  • func (rs *ReplicaServer) DiskReplace(ctx context.Context, req *enginerpc.DiskReplaceRequest) (*enginerpc.DiskReplaceResponse, error)
  • func (rs *ReplicaServer) RebuildingSet(ctx context.Context, req *enginerpc.RebuildingSetRequest) (*enginerpc.RebuildingSetResponse, error)
  • func (rs *ReplicaServer) ReplicaClose(ctx context.Context, req *emptypb.Empty) (*enginerpc.ReplicaCloseResponse, error)
  • func (rs *ReplicaServer) ReplicaCreate(ctx context.Context, req *enginerpc.ReplicaCreateRequest) (*enginerpc.ReplicaCreateResponse, error)
  • func (rs *ReplicaServer) ReplicaDelete(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)
  • func (rs *ReplicaServer) ReplicaExpand(ctx context.Context, req *enginerpc.ReplicaExpandRequest) (*enginerpc.ReplicaExpandResponse, error)
  • func (rs *ReplicaServer) ReplicaGet(ctx context.Context, req *emptypb.Empty) (*enginerpc.ReplicaGetResponse, error)
  • func (rs *ReplicaServer) ReplicaOpen(ctx context.Context, req *emptypb.Empty) (*enginerpc.ReplicaOpenResponse, error)
  • func (rs *ReplicaServer) ReplicaReload(ctx context.Context, req *emptypb.Empty) (*enginerpc.ReplicaReloadResponse, error)
  • func (rs *ReplicaServer) ReplicaRevert(ctx context.Context, req *enginerpc.ReplicaRevertRequest) (*enginerpc.ReplicaRevertResponse, error)
  • func (rs *ReplicaServer) ReplicaSnapshot(ctx context.Context, req *enginerpc.ReplicaSnapshotRequest) (*enginerpc.ReplicaSnapshotResponse, error)
  • func (rs *ReplicaServer) RevisionCounterSet(ctx context.Context, req *enginerpc.RevisionCounterSetRequest) (*enginerpc.RevisionCounterSetResponse, error)
  • func (rs *ReplicaServer) SnapshotMaxCountSet(ctx context.Context, req *enginerpc.SnapshotMaxCountSetRequest) (*enginerpc.SnapshotMaxCountSetResponse, error)
  • func (rs *ReplicaServer) SnapshotMaxSizeSet(ctx context.Context, req *enginerpc.SnapshotMaxSizeSetRequest) (*enginerpc.SnapshotMaxSizeSetResponse, error)
  • func (rs *ReplicaServer) UnmapMarkDiskChainRemovedSet(ctx context.Context, req *enginerpc.UnmapMarkDiskChainRemovedSetRequest) (*enginerpc.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 {
	enginerpc.UnimplementedReplicaServiceServer
	// contains filtered or unexported fields
}

func (*ReplicaServer) DiskMarkAsRemoved

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

func (*ReplicaServer) DiskPrepareRemove

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

func (*ReplicaServer) DiskRemove

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

func (*ReplicaServer) DiskReplace

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

func (*ReplicaServer) RebuildingSet

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

func (*ReplicaServer) ReplicaClose

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

func (*ReplicaServer) ReplicaCreate

func (rs *ReplicaServer) ReplicaCreate(ctx context.Context, req *enginerpc.ReplicaCreateRequest) (*enginerpc.ReplicaCreateResponse, error)

func (*ReplicaServer) ReplicaDelete

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

func (*ReplicaServer) ReplicaExpand

func (rs *ReplicaServer) ReplicaExpand(ctx context.Context, req *enginerpc.ReplicaExpandRequest) (*enginerpc.ReplicaExpandResponse, error)

func (*ReplicaServer) ReplicaGet

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

func (*ReplicaServer) ReplicaOpen

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

func (*ReplicaServer) ReplicaReload

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

func (*ReplicaServer) ReplicaRevert

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

func (*ReplicaServer) ReplicaSnapshot

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

func (*ReplicaServer) RevisionCounterSet

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

func (*ReplicaServer) SnapshotMaxCountSet

func (rs *ReplicaServer) SnapshotMaxCountSet(ctx context.Context, req *enginerpc.SnapshotMaxCountSetRequest) (*enginerpc.SnapshotMaxCountSetResponse, error)

func (*ReplicaServer) SnapshotMaxSizeSet

func (rs *ReplicaServer) SnapshotMaxSizeSet(ctx context.Context, req *enginerpc.SnapshotMaxSizeSetRequest) (*enginerpc.SnapshotMaxSizeSetResponse, error)

func (*ReplicaServer) UnmapMarkDiskChainRemovedSet

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