rpc

package
v0.7.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterReplicaServiceServer 

func RegisterReplicaServiceServer(s *grpc.Server, srv ReplicaServiceServer)

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 DiskInfo 

type DiskInfo struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parent               string            `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	Children             map[string]bool   `` /* 158-byte string literal not displayed */
	Removed              bool              `protobuf:"varint,4,opt,name=removed,proto3" json:"removed,omitempty"`
	UserCreated          bool              `protobuf:"varint,5,opt,name=userCreated,proto3" json:"userCreated,omitempty"`
	Created              string            `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	Size                 string            `protobuf:"bytes,7,opt,name=size,proto3" json:"size,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DiskInfo) Descriptor 

func (*DiskInfo) Descriptor() ([]byte, []int)

func (*DiskInfo) GetChildren 

func (m *DiskInfo) GetChildren() map[string]bool

func (*DiskInfo) GetCreated 

func (m *DiskInfo) GetCreated() string

func (*DiskInfo) GetLabels 

func (m *DiskInfo) GetLabels() map[string]string

func (*DiskInfo) GetName 

func (m *DiskInfo) GetName() string

func (*DiskInfo) GetParent 

func (m *DiskInfo) GetParent() string

func (*DiskInfo) GetRemoved 

func (m *DiskInfo) GetRemoved() bool

func (*DiskInfo) GetSize 

func (m *DiskInfo) GetSize() string

func (*DiskInfo) GetUserCreated 

func (m *DiskInfo) GetUserCreated() bool

func (*DiskInfo) ProtoMessage 

func (*DiskInfo) ProtoMessage()

func (*DiskInfo) Reset 

func (m *DiskInfo) Reset()

func (*DiskInfo) String 

func (m *DiskInfo) String() string

func (*DiskInfo) XXX_DiscardUnknown 

func (m *DiskInfo) XXX_DiscardUnknown()

func (*DiskInfo) XXX_Marshal 

func (m *DiskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskInfo) XXX_Merge 

func (m *DiskInfo) XXX_Merge(src proto.Message)

func (*DiskInfo) XXX_Size 

func (m *DiskInfo) XXX_Size() int

func (*DiskInfo) XXX_Unmarshal 

func (m *DiskInfo) XXX_Unmarshal(b []byte) error

type DiskMarkAsRemovedRequest 

type DiskMarkAsRemovedRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskMarkAsRemovedRequest) Descriptor 

func (*DiskMarkAsRemovedRequest) Descriptor() ([]byte, []int)

func (*DiskMarkAsRemovedRequest) GetName 

func (m *DiskMarkAsRemovedRequest) GetName() string

func (*DiskMarkAsRemovedRequest) ProtoMessage 

func (*DiskMarkAsRemovedRequest) ProtoMessage()

func (*DiskMarkAsRemovedRequest) Reset 

func (m *DiskMarkAsRemovedRequest) Reset()

func (*DiskMarkAsRemovedRequest) String 

func (m *DiskMarkAsRemovedRequest) String() string

func (*DiskMarkAsRemovedRequest) XXX_DiscardUnknown 

func (m *DiskMarkAsRemovedRequest) XXX_DiscardUnknown()

func (*DiskMarkAsRemovedRequest) XXX_Marshal 

func (m *DiskMarkAsRemovedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskMarkAsRemovedRequest) XXX_Merge 

func (m *DiskMarkAsRemovedRequest) XXX_Merge(src proto.Message)

func (*DiskMarkAsRemovedRequest) XXX_Size 

func (m *DiskMarkAsRemovedRequest) XXX_Size() int

func (*DiskMarkAsRemovedRequest) XXX_Unmarshal 

func (m *DiskMarkAsRemovedRequest) XXX_Unmarshal(b []byte) error

type DiskPrepareRemoveReply 

type DiskPrepareRemoveReply struct {
	Operations           []*PrepareRemoveAction `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DiskPrepareRemoveReply) Descriptor 

func (*DiskPrepareRemoveReply) Descriptor() ([]byte, []int)

func (*DiskPrepareRemoveReply) GetOperations 

func (m *DiskPrepareRemoveReply) GetOperations() []*PrepareRemoveAction

func (*DiskPrepareRemoveReply) ProtoMessage 

func (*DiskPrepareRemoveReply) ProtoMessage()

func (*DiskPrepareRemoveReply) Reset 

func (m *DiskPrepareRemoveReply) Reset()

func (*DiskPrepareRemoveReply) String 

func (m *DiskPrepareRemoveReply) String() string

func (*DiskPrepareRemoveReply) XXX_DiscardUnknown 

func (m *DiskPrepareRemoveReply) XXX_DiscardUnknown()

func (*DiskPrepareRemoveReply) XXX_Marshal 

func (m *DiskPrepareRemoveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskPrepareRemoveReply) XXX_Merge 

func (m *DiskPrepareRemoveReply) XXX_Merge(src proto.Message)

func (*DiskPrepareRemoveReply) XXX_Size 

func (m *DiskPrepareRemoveReply) XXX_Size() int

func (*DiskPrepareRemoveReply) XXX_Unmarshal 

func (m *DiskPrepareRemoveReply) XXX_Unmarshal(b []byte) error

type DiskPrepareRemoveRequest 

type DiskPrepareRemoveRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskPrepareRemoveRequest) Descriptor 

func (*DiskPrepareRemoveRequest) Descriptor() ([]byte, []int)

func (*DiskPrepareRemoveRequest) GetName 

func (m *DiskPrepareRemoveRequest) GetName() string

func (*DiskPrepareRemoveRequest) ProtoMessage 

func (*DiskPrepareRemoveRequest) ProtoMessage()

func (*DiskPrepareRemoveRequest) Reset 

func (m *DiskPrepareRemoveRequest) Reset()

func (*DiskPrepareRemoveRequest) String 

func (m *DiskPrepareRemoveRequest) String() string

func (*DiskPrepareRemoveRequest) XXX_DiscardUnknown 

func (m *DiskPrepareRemoveRequest) XXX_DiscardUnknown()

func (*DiskPrepareRemoveRequest) XXX_Marshal 

func (m *DiskPrepareRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskPrepareRemoveRequest) XXX_Merge 

func (m *DiskPrepareRemoveRequest) XXX_Merge(src proto.Message)

func (*DiskPrepareRemoveRequest) XXX_Size 

func (m *DiskPrepareRemoveRequest) XXX_Size() int

func (*DiskPrepareRemoveRequest) XXX_Unmarshal 

func (m *DiskPrepareRemoveRequest) XXX_Unmarshal(b []byte) error

type DiskRemoveRequest 

type DiskRemoveRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Force                bool     `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskRemoveRequest) Descriptor 

func (*DiskRemoveRequest) Descriptor() ([]byte, []int)

func (*DiskRemoveRequest) GetForce 

func (m *DiskRemoveRequest) GetForce() bool

func (*DiskRemoveRequest) GetName 

func (m *DiskRemoveRequest) GetName() string

func (*DiskRemoveRequest) ProtoMessage 

func (*DiskRemoveRequest) ProtoMessage()

func (*DiskRemoveRequest) Reset 

func (m *DiskRemoveRequest) Reset()

func (*DiskRemoveRequest) String 

func (m *DiskRemoveRequest) String() string

func (*DiskRemoveRequest) XXX_DiscardUnknown 

func (m *DiskRemoveRequest) XXX_DiscardUnknown()

func (*DiskRemoveRequest) XXX_Marshal 

func (m *DiskRemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskRemoveRequest) XXX_Merge 

func (m *DiskRemoveRequest) XXX_Merge(src proto.Message)

func (*DiskRemoveRequest) XXX_Size 

func (m *DiskRemoveRequest) XXX_Size() int

func (*DiskRemoveRequest) XXX_Unmarshal 

func (m *DiskRemoveRequest) XXX_Unmarshal(b []byte) error

type DiskReplaceRequest 

type DiskReplaceRequest struct {
	Target               string   `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiskReplaceRequest) Descriptor 

func (*DiskReplaceRequest) Descriptor() ([]byte, []int)

func (*DiskReplaceRequest) GetSource 

func (m *DiskReplaceRequest) GetSource() string

func (*DiskReplaceRequest) GetTarget 

func (m *DiskReplaceRequest) GetTarget() string

func (*DiskReplaceRequest) ProtoMessage 

func (*DiskReplaceRequest) ProtoMessage()

func (*DiskReplaceRequest) Reset 

func (m *DiskReplaceRequest) Reset()

func (*DiskReplaceRequest) String 

func (m *DiskReplaceRequest) String() string

func (*DiskReplaceRequest) XXX_DiscardUnknown 

func (m *DiskReplaceRequest) XXX_DiscardUnknown()

func (*DiskReplaceRequest) XXX_Marshal 

func (m *DiskReplaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskReplaceRequest) XXX_Merge 

func (m *DiskReplaceRequest) XXX_Merge(src proto.Message)

func (*DiskReplaceRequest) XXX_Size 

func (m *DiskReplaceRequest) XXX_Size() int

func (*DiskReplaceRequest) XXX_Unmarshal 

func (m *DiskReplaceRequest) XXX_Unmarshal(b []byte) error

type PrepareRemoveAction 

type PrepareRemoveAction struct {
	Action               string   `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Target               string   `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrepareRemoveAction) Descriptor 

func (*PrepareRemoveAction) Descriptor() ([]byte, []int)

func (*PrepareRemoveAction) GetAction 

func (m *PrepareRemoveAction) GetAction() string

func (*PrepareRemoveAction) GetSource 

func (m *PrepareRemoveAction) GetSource() string

func (*PrepareRemoveAction) GetTarget 

func (m *PrepareRemoveAction) GetTarget() string

func (*PrepareRemoveAction) ProtoMessage 

func (*PrepareRemoveAction) ProtoMessage()

func (*PrepareRemoveAction) Reset 

func (m *PrepareRemoveAction) Reset()

func (*PrepareRemoveAction) String 

func (m *PrepareRemoveAction) String() string

func (*PrepareRemoveAction) XXX_DiscardUnknown 

func (m *PrepareRemoveAction) XXX_DiscardUnknown()

func (*PrepareRemoveAction) XXX_Marshal 

func (m *PrepareRemoveAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareRemoveAction) XXX_Merge 

func (m *PrepareRemoveAction) XXX_Merge(src proto.Message)

func (*PrepareRemoveAction) XXX_Size 

func (m *PrepareRemoveAction) XXX_Size() int

func (*PrepareRemoveAction) XXX_Unmarshal 

func (m *PrepareRemoveAction) XXX_Unmarshal(b []byte) error

type RebuildingSetRequest 

type RebuildingSetRequest struct {
	Rebuilding           bool     `protobuf:"varint,1,opt,name=rebuilding,proto3" json:"rebuilding,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RebuildingSetRequest) Descriptor 

func (*RebuildingSetRequest) Descriptor() ([]byte, []int)

func (*RebuildingSetRequest) GetRebuilding 

func (m *RebuildingSetRequest) GetRebuilding() bool

func (*RebuildingSetRequest) ProtoMessage 

func (*RebuildingSetRequest) ProtoMessage()

func (*RebuildingSetRequest) Reset 

func (m *RebuildingSetRequest) Reset()

func (*RebuildingSetRequest) String 

func (m *RebuildingSetRequest) String() string

func (*RebuildingSetRequest) XXX_DiscardUnknown 

func (m *RebuildingSetRequest) XXX_DiscardUnknown()

func (*RebuildingSetRequest) XXX_Marshal 

func (m *RebuildingSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RebuildingSetRequest) XXX_Merge 

func (m *RebuildingSetRequest) XXX_Merge(src proto.Message)

func (*RebuildingSetRequest) XXX_Size 

func (m *RebuildingSetRequest) XXX_Size() int

func (*RebuildingSetRequest) XXX_Unmarshal 

func (m *RebuildingSetRequest) XXX_Unmarshal(b []byte) error

type Replica 

type Replica struct {
	Dirty                bool                 `protobuf:"varint,1,opt,name=dirty,proto3" json:"dirty,omitempty"`
	Rebuilding           bool                 `protobuf:"varint,2,opt,name=rebuilding,proto3" json:"rebuilding,omitempty"`
	Head                 string               `protobuf:"bytes,3,opt,name=head,proto3" json:"head,omitempty"`
	Parent               string               `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
	Size                 string               `protobuf:"bytes,5,opt,name=size,proto3" json:"size,omitempty"`
	SectorSize           int64                `protobuf:"varint,6,opt,name=sectorSize,proto3" json:"sectorSize,omitempty"`
	BackingFile          string               `protobuf:"bytes,7,opt,name=backingFile,proto3" json:"backingFile,omitempty"`
	State                string               `protobuf:"bytes,8,opt,name=state,proto3" json:"state,omitempty"`
	Chain                []string             `protobuf:"bytes,9,rep,name=chain,proto3" json:"chain,omitempty"`
	Disks                map[string]*DiskInfo `` /* 152-byte string literal not displayed */
	RemainSnapshots      int32                `protobuf:"varint,11,opt,name=remainSnapshots,proto3" json:"remainSnapshots,omitempty"`
	RevisionCounter      int64                `protobuf:"varint,12,opt,name=revisionCounter,proto3" json:"revisionCounter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Replica) Descriptor 

func (*Replica) Descriptor() ([]byte, []int)

func (*Replica) GetBackingFile 

func (m *Replica) GetBackingFile() string

func (*Replica) GetChain 

func (m *Replica) GetChain() []string

func (*Replica) GetDirty 

func (m *Replica) GetDirty() bool

func (*Replica) GetDisks 

func (m *Replica) GetDisks() map[string]*DiskInfo

func (*Replica) GetHead 

func (m *Replica) GetHead() string

func (*Replica) GetParent 

func (m *Replica) GetParent() string

func (*Replica) GetRebuilding 

func (m *Replica) GetRebuilding() bool

func (*Replica) GetRemainSnapshots 

func (m *Replica) GetRemainSnapshots() int32

func (*Replica) GetRevisionCounter 

func (m *Replica) GetRevisionCounter() int64

func (*Replica) GetSectorSize 

func (m *Replica) GetSectorSize() int64

func (*Replica) GetSize 

func (m *Replica) GetSize() string

func (*Replica) GetState 

func (m *Replica) GetState() string

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) Reset 

func (m *Replica) Reset()

func (*Replica) String 

func (m *Replica) String() string

func (*Replica) XXX_DiscardUnknown 

func (m *Replica) XXX_DiscardUnknown()

func (*Replica) XXX_Marshal 

func (m *Replica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Replica) XXX_Merge 

func (m *Replica) XXX_Merge(src proto.Message)

func (*Replica) XXX_Size 

func (m *Replica) XXX_Size() int

func (*Replica) XXX_Unmarshal 

func (m *Replica) XXX_Unmarshal(b []byte) error

type ReplicaCreateRequest 

type ReplicaCreateRequest struct {
	Size                 string   `protobuf:"bytes,1,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaCreateRequest) Descriptor 

func (*ReplicaCreateRequest) Descriptor() ([]byte, []int)

func (*ReplicaCreateRequest) GetSize 

func (m *ReplicaCreateRequest) GetSize() string

func (*ReplicaCreateRequest) ProtoMessage 

func (*ReplicaCreateRequest) ProtoMessage()

func (*ReplicaCreateRequest) Reset 

func (m *ReplicaCreateRequest) Reset()

func (*ReplicaCreateRequest) String 

func (m *ReplicaCreateRequest) String() string

func (*ReplicaCreateRequest) XXX_DiscardUnknown 

func (m *ReplicaCreateRequest) XXX_DiscardUnknown()

func (*ReplicaCreateRequest) XXX_Marshal 

func (m *ReplicaCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaCreateRequest) XXX_Merge 

func (m *ReplicaCreateRequest) XXX_Merge(src proto.Message)

func (*ReplicaCreateRequest) XXX_Size 

func (m *ReplicaCreateRequest) XXX_Size() int

func (*ReplicaCreateRequest) XXX_Unmarshal 

func (m *ReplicaCreateRequest) XXX_Unmarshal(b []byte) 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 ReplicaRevertRequest 

type ReplicaRevertRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Created              string   `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaRevertRequest) Descriptor 

func (*ReplicaRevertRequest) Descriptor() ([]byte, []int)

func (*ReplicaRevertRequest) GetCreated 

func (m *ReplicaRevertRequest) GetCreated() string

func (*ReplicaRevertRequest) GetName 

func (m *ReplicaRevertRequest) GetName() string

func (*ReplicaRevertRequest) ProtoMessage 

func (*ReplicaRevertRequest) ProtoMessage()

func (*ReplicaRevertRequest) Reset 

func (m *ReplicaRevertRequest) Reset()

func (*ReplicaRevertRequest) String 

func (m *ReplicaRevertRequest) String() string

func (*ReplicaRevertRequest) XXX_DiscardUnknown 

func (m *ReplicaRevertRequest) XXX_DiscardUnknown()

func (*ReplicaRevertRequest) XXX_Marshal 

func (m *ReplicaRevertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaRevertRequest) XXX_Merge 

func (m *ReplicaRevertRequest) XXX_Merge(src proto.Message)

func (*ReplicaRevertRequest) XXX_Size 

func (m *ReplicaRevertRequest) XXX_Size() int

func (*ReplicaRevertRequest) XXX_Unmarshal 

func (m *ReplicaRevertRequest) XXX_Unmarshal(b []byte) 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 *DiskMarkAsRemovedRequest) (*Replica, error)

func (*ReplicaServer) DiskPrepareRemove 

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

func (*ReplicaServer) DiskRemove 

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

func (*ReplicaServer) DiskReplace 

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

func (*ReplicaServer) RebuildingSet 

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

func (*ReplicaServer) ReplicaClose 

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

func (*ReplicaServer) ReplicaCreate 

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

func (*ReplicaServer) ReplicaDelete 

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

func (*ReplicaServer) ReplicaGet 

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

func (*ReplicaServer) ReplicaOpen 

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

func (*ReplicaServer) ReplicaReload 

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

func (*ReplicaServer) ReplicaRevert 

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

func (*ReplicaServer) ReplicaSnapshot 

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

func (*ReplicaServer) RevisionCounterSet 

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

type ReplicaServiceClient 

type ReplicaServiceClient interface {
	ReplicaCreate(ctx context.Context, in *ReplicaCreateRequest, opts ...grpc.CallOption) (*Replica, error)
	ReplicaDelete(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	ReplicaGet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaOpen(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaClose(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaReload(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Replica, error)
	ReplicaRevert(ctx context.Context, in *ReplicaRevertRequest, opts ...grpc.CallOption) (*Replica, error)
	ReplicaSnapshot(ctx context.Context, in *ReplicaSnapshotRequest, opts ...grpc.CallOption) (*Replica, error)
	DiskRemove(ctx context.Context, in *DiskRemoveRequest, opts ...grpc.CallOption) (*Replica, error)
	DiskReplace(ctx context.Context, in *DiskReplaceRequest, opts ...grpc.CallOption) (*Replica, error)
	DiskPrepareRemove(ctx context.Context, in *DiskPrepareRemoveRequest, opts ...grpc.CallOption) (*DiskPrepareRemoveReply, error)
	DiskMarkAsRemoved(ctx context.Context, in *DiskMarkAsRemovedRequest, opts ...grpc.CallOption) (*Replica, error)
	RebuildingSet(ctx context.Context, in *RebuildingSetRequest, opts ...grpc.CallOption) (*Replica, error)
	RevisionCounterSet(ctx context.Context, in *RevisionCounterSetRequest, opts ...grpc.CallOption) (*Replica, error)
}

ReplicaServiceClient is the client API for ReplicaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewReplicaServiceClient 

func NewReplicaServiceClient(cc *grpc.ClientConn) ReplicaServiceClient

type ReplicaServiceServer 

type ReplicaServiceServer interface {
	ReplicaCreate(context.Context, *ReplicaCreateRequest) (*Replica, error)
	ReplicaDelete(context.Context, *empty.Empty) (*empty.Empty, error)
	ReplicaGet(context.Context, *empty.Empty) (*Replica, error)
	ReplicaOpen(context.Context, *empty.Empty) (*Replica, error)
	ReplicaClose(context.Context, *empty.Empty) (*Replica, error)
	ReplicaReload(context.Context, *empty.Empty) (*Replica, error)
	ReplicaRevert(context.Context, *ReplicaRevertRequest) (*Replica, error)
	ReplicaSnapshot(context.Context, *ReplicaSnapshotRequest) (*Replica, error)
	DiskRemove(context.Context, *DiskRemoveRequest) (*Replica, error)
	DiskReplace(context.Context, *DiskReplaceRequest) (*Replica, error)
	DiskPrepareRemove(context.Context, *DiskPrepareRemoveRequest) (*DiskPrepareRemoveReply, error)
	DiskMarkAsRemoved(context.Context, *DiskMarkAsRemovedRequest) (*Replica, error)
	RebuildingSet(context.Context, *RebuildingSetRequest) (*Replica, error)
	RevisionCounterSet(context.Context, *RevisionCounterSetRequest) (*Replica, error)
}

ReplicaServiceServer is the server API for ReplicaService service.

type ReplicaSnapshotRequest 

type ReplicaSnapshotRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UserCreated          bool              `protobuf:"varint,2,opt,name=userCreated,proto3" json:"userCreated,omitempty"`
	Created              string            `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ReplicaSnapshotRequest) Descriptor 

func (*ReplicaSnapshotRequest) Descriptor() ([]byte, []int)

func (*ReplicaSnapshotRequest) GetCreated 

func (m *ReplicaSnapshotRequest) GetCreated() string

func (*ReplicaSnapshotRequest) GetLabels 

func (m *ReplicaSnapshotRequest) GetLabels() map[string]string

func (*ReplicaSnapshotRequest) GetName 

func (m *ReplicaSnapshotRequest) GetName() string

func (*ReplicaSnapshotRequest) GetUserCreated 

func (m *ReplicaSnapshotRequest) GetUserCreated() bool

func (*ReplicaSnapshotRequest) ProtoMessage 

func (*ReplicaSnapshotRequest) ProtoMessage()

func (*ReplicaSnapshotRequest) Reset 

func (m *ReplicaSnapshotRequest) Reset()

func (*ReplicaSnapshotRequest) String 

func (m *ReplicaSnapshotRequest) String() string

func (*ReplicaSnapshotRequest) XXX_DiscardUnknown 

func (m *ReplicaSnapshotRequest) XXX_DiscardUnknown()

func (*ReplicaSnapshotRequest) XXX_Marshal 

func (m *ReplicaSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaSnapshotRequest) XXX_Merge 

func (m *ReplicaSnapshotRequest) XXX_Merge(src proto.Message)

func (*ReplicaSnapshotRequest) XXX_Size 

func (m *ReplicaSnapshotRequest) XXX_Size() int

func (*ReplicaSnapshotRequest) XXX_Unmarshal 

func (m *ReplicaSnapshotRequest) XXX_Unmarshal(b []byte) error

type RevisionCounterSetRequest 

type RevisionCounterSetRequest struct {
	Counter              int64    `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevisionCounterSetRequest) Descriptor 

func (*RevisionCounterSetRequest) Descriptor() ([]byte, []int)

func (*RevisionCounterSetRequest) GetCounter 

func (m *RevisionCounterSetRequest) GetCounter() int64

func (*RevisionCounterSetRequest) ProtoMessage 

func (*RevisionCounterSetRequest) ProtoMessage()

func (*RevisionCounterSetRequest) Reset 

func (m *RevisionCounterSetRequest) Reset()

func (*RevisionCounterSetRequest) String 

func (m *RevisionCounterSetRequest) String() string

func (*RevisionCounterSetRequest) XXX_DiscardUnknown 

func (m *RevisionCounterSetRequest) XXX_DiscardUnknown()

func (*RevisionCounterSetRequest) XXX_Marshal 

func (m *RevisionCounterSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RevisionCounterSetRequest) XXX_Merge 

func (m *RevisionCounterSetRequest) XXX_Merge(src proto.Message)

func (*RevisionCounterSetRequest) XXX_Size 

func (m *RevisionCounterSetRequest) XXX_Size() int

func (*RevisionCounterSetRequest) XXX_Unmarshal 

func (m *RevisionCounterSetRequest) XXX_Unmarshal(b []byte) error

type UnimplementedReplicaServiceServer 

type UnimplementedReplicaServiceServer struct {
}

UnimplementedReplicaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicaServiceServer) DiskMarkAsRemoved 

func (*UnimplementedReplicaServiceServer) DiskMarkAsRemoved(ctx context.Context, req *DiskMarkAsRemovedRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) DiskPrepareRemove 

func (*UnimplementedReplicaServiceServer) DiskPrepareRemove(ctx context.Context, req *DiskPrepareRemoveRequest) (*DiskPrepareRemoveReply, error)

func (*UnimplementedReplicaServiceServer) DiskRemove 

func (*UnimplementedReplicaServiceServer) DiskRemove(ctx context.Context, req *DiskRemoveRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) DiskReplace 

func (*UnimplementedReplicaServiceServer) DiskReplace(ctx context.Context, req *DiskReplaceRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) RebuildingSet 

func (*UnimplementedReplicaServiceServer) RebuildingSet(ctx context.Context, req *RebuildingSetRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaClose 

func (*UnimplementedReplicaServiceServer) ReplicaClose(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaCreate 

func (*UnimplementedReplicaServiceServer) ReplicaCreate(ctx context.Context, req *ReplicaCreateRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaDelete 

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

func (*UnimplementedReplicaServiceServer) ReplicaGet 

func (*UnimplementedReplicaServiceServer) ReplicaGet(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaOpen 

func (*UnimplementedReplicaServiceServer) ReplicaOpen(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaReload 

func (*UnimplementedReplicaServiceServer) ReplicaReload(ctx context.Context, req *empty.Empty) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaRevert 

func (*UnimplementedReplicaServiceServer) ReplicaRevert(ctx context.Context, req *ReplicaRevertRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) ReplicaSnapshot 

func (*UnimplementedReplicaServiceServer) ReplicaSnapshot(ctx context.Context, req *ReplicaSnapshotRequest) (*Replica, error)

func (*UnimplementedReplicaServiceServer) RevisionCounterSet 

func (*UnimplementedReplicaServiceServer) RevisionCounterSet(ctx context.Context, req *RevisionCounterSetRequest) (*Replica, 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.