rpc

package
v1.7.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 18, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GRPCRetryCount = 5
)

Variables

This section is empty.

Functions

func GetControllerGRPCServer 

func GetControllerGRPCServer(volumeName, instanceName string, c *controller.Controller) *grpc.Server

Types

type ControllerHealthCheckServer 

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

func NewControllerHealthCheckServer 

func NewControllerHealthCheckServer(cs *ControllerServer) *ControllerHealthCheckServer

func (*ControllerHealthCheckServer) Check 

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

func (*ControllerHealthCheckServer) Watch 

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

type ControllerServer 

type ControllerServer struct {
	enginerpc.UnimplementedControllerServiceServer
	// contains filtered or unexported fields
}

func NewControllerServer 

func NewControllerServer(c *controller.Controller) *ControllerServer

func (*ControllerServer) ControllerReplicaCreate added in v1.1.0 

func (cs *ControllerServer) ControllerReplicaCreate(ctx context.Context, req *enginerpc.ControllerReplicaCreateRequest) (*enginerpc.ControllerReplica, error)

func (*ControllerServer) JournalList 

func (cs *ControllerServer) JournalList(ctx context.Context, req *enginerpc.JournalListRequest) (*emptypb.Empty, error)

func (*ControllerServer) MetricsGet added in v1.4.0 

func (cs *ControllerServer) MetricsGet(ctx context.Context, req *emptypb.Empty) (*enginerpc.MetricsGetReply, error)

func (*ControllerServer) ReplicaDelete 

func (cs *ControllerServer) ReplicaDelete(ctx context.Context, req *enginerpc.ReplicaAddress) (*emptypb.Empty, error)

func (*ControllerServer) ReplicaGet 

func (cs *ControllerServer) ReplicaGet(ctx context.Context, req *enginerpc.ReplicaAddress) (*enginerpc.ControllerReplica, error)

func (*ControllerServer) ReplicaList 

func (cs *ControllerServer) ReplicaList(ctx context.Context, req *emptypb.Empty) (*enginerpc.ReplicaListReply, error)

func (*ControllerServer) ReplicaPrepareRebuild 

func (cs *ControllerServer) ReplicaPrepareRebuild(ctx context.Context, req *enginerpc.ReplicaAddress) (*enginerpc.ReplicaPrepareRebuildReply, error)

func (*ControllerServer) ReplicaUpdate 

func (cs *ControllerServer) ReplicaUpdate(ctx context.Context, req *enginerpc.ControllerReplica) (*enginerpc.ControllerReplica, error)

func (*ControllerServer) ReplicaVerifyRebuild 

func (cs *ControllerServer) ReplicaVerifyRebuild(ctx context.Context, req *enginerpc.ReplicaAddress) (*enginerpc.ControllerReplica, error)

func (*ControllerServer) VersionDetailGet 

func (cs *ControllerServer) VersionDetailGet(ctx context.Context, req *emptypb.Empty) (*enginerpc.VersionDetailGetReply, error)

func (*ControllerServer) VolumeExpand 

func (cs *ControllerServer) VolumeExpand(ctx context.Context, req *enginerpc.VolumeExpandRequest) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeFrontendShutdown 

func (cs *ControllerServer) VolumeFrontendShutdown(ctx context.Context, req *emptypb.Empty) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeFrontendStart 

func (cs *ControllerServer) VolumeFrontendStart(ctx context.Context, req *enginerpc.VolumeFrontendStartRequest) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeGet 

func (cs *ControllerServer) VolumeGet(ctx context.Context, req *emptypb.Empty) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeRevert 

func (cs *ControllerServer) VolumeRevert(ctx context.Context, req *enginerpc.VolumeRevertRequest) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeShutdown 

func (cs *ControllerServer) VolumeShutdown(ctx context.Context, req *emptypb.Empty) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeSnapshot 

func (cs *ControllerServer) VolumeSnapshot(ctx context.Context, req *enginerpc.VolumeSnapshotRequest) (*enginerpc.VolumeSnapshotReply, error)

func (*ControllerServer) VolumeSnapshotMaxCountSet added in v1.6.0 

func (cs *ControllerServer) VolumeSnapshotMaxCountSet(ctx context.Context, req *enginerpc.VolumeSnapshotMaxCountSetRequest) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeSnapshotMaxSizeSet added in v1.6.0 

func (cs *ControllerServer) VolumeSnapshotMaxSizeSet(ctx context.Context, req *enginerpc.VolumeSnapshotMaxSizeSetRequest) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeStart 

func (cs *ControllerServer) VolumeStart(ctx context.Context, req *enginerpc.VolumeStartRequest) (*enginerpc.Volume, error)

func (*ControllerServer) VolumeUnmapMarkSnapChainRemovedSet added in v1.4.0 

func (cs *ControllerServer) VolumeUnmapMarkSnapChainRemovedSet(ctx context.Context, req *enginerpc.VolumeUnmapMarkSnapChainRemovedSetRequest) (*enginerpc.Volume, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.