volumes

package
v0.0.0-...-a9890c3 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	VolumeStatus_name = map[int32]string{
		0:  "PENDING",
		1:  "CREATING",
		2:  "AVAILABLE",
		3:  "INUSE",
		4:  "BACKINGUP",
		5:  "RESTORING",
		6:  "RESIZING",
		7:  "DELETING",
		8:  "DELETED",
		99: "ERROR",
	}
	VolumeStatus_value = map[string]int32{
		"PENDING":   0,
		"CREATING":  1,
		"AVAILABLE": 2,
		"INUSE":     3,
		"BACKINGUP": 4,
		"RESTORING": 5,
		"RESIZING":  6,
		"DELETING":  7,
		"DELETED":   8,
		"ERROR":     99,
	}
)

Enum value maps for VolumeStatus.

View Source 
var (
	BlockCommandRequest_Cmd_name = map[int32]string{
		0: "WRITE",
		1: "READ",
		2: "ZERO",
	}
	BlockCommandRequest_Cmd_value = map[string]int32{
		"WRITE": 0,
		"READ":  1,
		"ZERO":  2,
	}
)

Enum value maps for BlockCommandRequest_Cmd.

View Source 
var File_volumes_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BlockCommandRequest 

type BlockCommandRequest struct {
	Volume string                  `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	Cmd    BlockCommandRequest_Cmd `protobuf:"varint,2,opt,name=cmd,proto3,enum=vpc.volumes.BlockCommandRequest_Cmd" json:"cmd,omitempty"`
	Offset int64                   `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Length int32                   `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	Data   []byte                  `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockCommandRequest) Descriptor deprecated 

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

Deprecated: Use BlockCommandRequest.ProtoReflect.Descriptor instead.

func (*BlockCommandRequest) GetCmd 

func (x *BlockCommandRequest) GetCmd() BlockCommandRequest_Cmd

func (*BlockCommandRequest) GetData 

func (x *BlockCommandRequest) GetData() []byte

func (*BlockCommandRequest) GetLength 

func (x *BlockCommandRequest) GetLength() int32

func (*BlockCommandRequest) GetOffset 

func (x *BlockCommandRequest) GetOffset() int64

func (*BlockCommandRequest) GetVolume 

func (x *BlockCommandRequest) GetVolume() string

func (*BlockCommandRequest) ProtoMessage 

func (*BlockCommandRequest) ProtoMessage()

func (*BlockCommandRequest) ProtoReflect 

func (x *BlockCommandRequest) ProtoReflect() protoreflect.Message

func (*BlockCommandRequest) Reset 

func (x *BlockCommandRequest) Reset()

func (*BlockCommandRequest) String 

func (x *BlockCommandRequest) String() string

type BlockCommandRequest_Cmd 

type BlockCommandRequest_Cmd int32
const (
	BlockCommandRequest_WRITE BlockCommandRequest_Cmd = 0
	BlockCommandRequest_READ  BlockCommandRequest_Cmd = 1
	BlockCommandRequest_ZERO  BlockCommandRequest_Cmd = 2
)

func (BlockCommandRequest_Cmd) Descriptor 

func (BlockCommandRequest_Cmd) Descriptor() protoreflect.EnumDescriptor

func (BlockCommandRequest_Cmd) Enum 

func (x BlockCommandRequest_Cmd) Enum() *BlockCommandRequest_Cmd

func (BlockCommandRequest_Cmd) EnumDescriptor deprecated 

func (BlockCommandRequest_Cmd) EnumDescriptor() ([]byte, []int)

Deprecated: Use BlockCommandRequest_Cmd.Descriptor instead.

func (BlockCommandRequest_Cmd) Number 

func (x BlockCommandRequest_Cmd) Number() protoreflect.EnumNumber

func (BlockCommandRequest_Cmd) String 

func (x BlockCommandRequest_Cmd) String() string

func (BlockCommandRequest_Cmd) Type 

func (BlockCommandRequest_Cmd) Type() protoreflect.EnumType

type BlockCommandResponse 

type BlockCommandResponse struct {
	Volume  string `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	RetryAt string `protobuf:"bytes,2,opt,name=retryAt,proto3" json:"retryAt,omitempty"` //peer ID to retry to request at - i.e. peer not leader
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Error   string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockCommandResponse) Descriptor deprecated 

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

Deprecated: Use BlockCommandResponse.ProtoReflect.Descriptor instead.

func (*BlockCommandResponse) GetData 

func (x *BlockCommandResponse) GetData() []byte

func (*BlockCommandResponse) GetError 

func (x *BlockCommandResponse) GetError() string

func (*BlockCommandResponse) GetRetryAt 

func (x *BlockCommandResponse) GetRetryAt() string

func (*BlockCommandResponse) GetVolume 

func (x *BlockCommandResponse) GetVolume() string

func (*BlockCommandResponse) ProtoMessage 

func (*BlockCommandResponse) ProtoMessage()

func (*BlockCommandResponse) ProtoReflect 

func (x *BlockCommandResponse) ProtoReflect() protoreflect.Message

func (*BlockCommandResponse) Reset 

func (x *BlockCommandResponse) Reset()

func (*BlockCommandResponse) String 

func (x *BlockCommandResponse) String() string

type PeerNegotiate 

type PeerNegotiate struct {
	IAm    string `protobuf:"bytes,1,opt,name=IAm,proto3" json:"IAm,omitempty"`
	YouAre string `protobuf:"bytes,2,opt,name=YouAre,proto3" json:"YouAre,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerNegotiate) Descriptor deprecated 

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

Deprecated: Use PeerNegotiate.ProtoReflect.Descriptor instead.

func (*PeerNegotiate) GetIAm 

func (x *PeerNegotiate) GetIAm() string

func (*PeerNegotiate) GetYouAre 

func (x *PeerNegotiate) GetYouAre() string

func (*PeerNegotiate) ProtoMessage 

func (*PeerNegotiate) ProtoMessage()

func (*PeerNegotiate) ProtoReflect 

func (x *PeerNegotiate) ProtoReflect() protoreflect.Message

func (*PeerNegotiate) Reset 

func (x *PeerNegotiate) Reset()

func (*PeerNegotiate) String 

func (x *PeerNegotiate) String() string

type PeerPing 

type PeerPing struct {
	Ts int64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerPing) Descriptor deprecated 

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

Deprecated: Use PeerPing.ProtoReflect.Descriptor instead.

func (*PeerPing) GetTs 

func (x *PeerPing) GetTs() int64

func (*PeerPing) ProtoMessage 

func (*PeerPing) ProtoMessage()

func (*PeerPing) ProtoReflect 

func (x *PeerPing) ProtoReflect() protoreflect.Message

func (*PeerPing) Reset 

func (x *PeerPing) Reset()

func (*PeerPing) String 

func (x *PeerPing) String() string

type PeerRPC 

type PeerRPC struct {
	Metadata *RPCMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to RPC:
	//	*PeerRPC_RaftRPC
	//	*PeerRPC_PeerPing
	//	*PeerRPC_BlockCommand
	//	*PeerRPC_BlockCommandResponse
	RPC   isPeerRPC_RPC `protobuf_oneof:"RPC"`
	Async bool          `protobuf:"varint,101,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerRPC) Descriptor deprecated 

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

Deprecated: Use PeerRPC.ProtoReflect.Descriptor instead.

func (*PeerRPC) GetAsync 

func (x *PeerRPC) GetAsync() bool

func (*PeerRPC) GetBlockCommand 

func (x *PeerRPC) GetBlockCommand() *BlockCommandRequest

func (*PeerRPC) GetBlockCommandResponse 

func (x *PeerRPC) GetBlockCommandResponse() *BlockCommandResponse

func (*PeerRPC) GetMetadata 

func (x *PeerRPC) GetMetadata() *RPCMetadata

func (*PeerRPC) GetPeerPing 

func (x *PeerRPC) GetPeerPing() *PeerPing

func (*PeerRPC) GetRPC 

func (m *PeerRPC) GetRPC() isPeerRPC_RPC

func (*PeerRPC) GetRaftRPC 

func (x *PeerRPC) GetRaftRPC() *RaftRPC

func (*PeerRPC) ProtoMessage 

func (*PeerRPC) ProtoMessage()

func (*PeerRPC) ProtoReflect 

func (x *PeerRPC) ProtoReflect() protoreflect.Message

func (*PeerRPC) Reset 

func (x *PeerRPC) Reset()

func (*PeerRPC) String 

func (x *PeerRPC) String() string

type PeerRPC_BlockCommand 

type PeerRPC_BlockCommand struct {
	BlockCommand *BlockCommandRequest `protobuf:"bytes,4,opt,name=BlockCommand,proto3,oneof"`
}

type PeerRPC_BlockCommandResponse 

type PeerRPC_BlockCommandResponse struct {
	BlockCommandResponse *BlockCommandResponse `protobuf:"bytes,5,opt,name=BlockCommandResponse,proto3,oneof"`
}

type PeerRPC_PeerPing 

type PeerRPC_PeerPing struct {
	PeerPing *PeerPing `protobuf:"bytes,3,opt,name=PeerPing,proto3,oneof"`
}

type PeerRPC_RaftRPC 

type PeerRPC_RaftRPC struct {
	RaftRPC *RaftRPC `protobuf:"bytes,2,opt,name=RaftRPC,proto3,oneof"`
}

type RPCMetadata 

type RPCMetadata struct {
	LeaderOnly      bool  `protobuf:"varint,1,opt,name=leaderOnly,proto3" json:"leaderOnly,omitempty"` //to prevent stale reads if no caching on client side - all writes must still go to leader
	AllowForwarding bool  `protobuf:"varint,2,opt,name=allowForwarding,proto3" json:"allowForwarding,omitempty"`
	TTL             int32 `protobuf:"varint,3,opt,name=TTL,proto3" json:"TTL,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCMetadata) Descriptor deprecated 

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

Deprecated: Use RPCMetadata.ProtoReflect.Descriptor instead.

func (*RPCMetadata) GetAllowForwarding 

func (x *RPCMetadata) GetAllowForwarding() bool

func (*RPCMetadata) GetLeaderOnly 

func (x *RPCMetadata) GetLeaderOnly() bool

func (*RPCMetadata) GetTTL 

func (x *RPCMetadata) GetTTL() int32

func (*RPCMetadata) ProtoMessage 

func (*RPCMetadata) ProtoMessage()

func (*RPCMetadata) ProtoReflect 

func (x *RPCMetadata) ProtoReflect() protoreflect.Message

func (*RPCMetadata) Reset 

func (x *RPCMetadata) Reset()

func (*RPCMetadata) String 

func (x *RPCMetadata) String() string

type RaftRPC 

type RaftRPC struct {
	Volume  string `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	Type    int32  `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Command []byte `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`
	Error   string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftRPC) Descriptor deprecated 

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

Deprecated: Use RaftRPC.ProtoReflect.Descriptor instead.

func (*RaftRPC) GetCommand 

func (x *RaftRPC) GetCommand() []byte

func (*RaftRPC) GetError 

func (x *RaftRPC) GetError() string

func (*RaftRPC) GetType 

func (x *RaftRPC) GetType() int32

func (*RaftRPC) GetVolume 

func (x *RaftRPC) GetVolume() string

func (*RaftRPC) ProtoMessage 

func (*RaftRPC) ProtoMessage()

func (*RaftRPC) ProtoReflect 

func (x *RaftRPC) ProtoReflect() protoreflect.Message

func (*RaftRPC) Reset 

func (x *RaftRPC) Reset()

func (*RaftRPC) String 

func (x *RaftRPC) String() string

type Snapshot 

type Snapshot struct {
	Id               string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Volume           string            `protobuf:"bytes,2,opt,name=volume,proto3" json:"volume,omitempty"`
	Status           VolumeStatus      `protobuf:"varint,3,opt,name=status,proto3,enum=vpc.volumes.VolumeStatus" json:"status,omitempty"`
	Metadata         map[string][]byte `` /* 157-byte string literal not displayed */
	CreatedAt        string            `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt        string            `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Size             int64             `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	Store            string            `protobuf:"bytes,8,opt,name=store,proto3" json:"store,omitempty"`
	AvailabilityArea string            `protobuf:"bytes,9,opt,name=availability_area,json=availabilityArea,proto3" json:"availability_area,omitempty"`
	// contains filtered or unexported fields
}

func (*Snapshot) Descriptor deprecated 

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

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) GetAvailabilityArea 

func (x *Snapshot) GetAvailabilityArea() string

func (*Snapshot) GetCreatedAt 

func (x *Snapshot) GetCreatedAt() string

func (*Snapshot) GetId 

func (x *Snapshot) GetId() string

func (*Snapshot) GetMetadata 

func (x *Snapshot) GetMetadata() map[string][]byte

func (*Snapshot) GetSize 

func (x *Snapshot) GetSize() int64

func (*Snapshot) GetStatus 

func (x *Snapshot) GetStatus() VolumeStatus

func (*Snapshot) GetStore 

func (x *Snapshot) GetStore() string

func (*Snapshot) GetUpdatedAt 

func (x *Snapshot) GetUpdatedAt() string

func (*Snapshot) GetVolume 

func (x *Snapshot) GetVolume() string

func (*Snapshot) ProtoMessage 

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect 

func (x *Snapshot) ProtoReflect() protoreflect.Message

func (*Snapshot) Reset 

func (x *Snapshot) Reset()

func (*Snapshot) String 

func (x *Snapshot) String() string

type Volume 

type Volume struct {
	Account          int32             `protobuf:"varint,1,opt,name=account,proto3" json:"account,omitempty"`
	Id               string            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Status           VolumeStatus      `protobuf:"varint,3,opt,name=status,proto3,enum=vpc.volumes.VolumeStatus" json:"status,omitempty"`
	Metadata         map[string][]byte `` /* 157-byte string literal not displayed */
	CreatedAt        string            `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt        string            `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Size             int64             `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	Store            string            `protobuf:"bytes,8,opt,name=store,proto3" json:"store,omitempty"`
	AvailabilityArea string            `protobuf:"bytes,9,opt,name=availability_area,json=availabilityArea,proto3" json:"availability_area,omitempty"`
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated 

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetAccount 

func (x *Volume) GetAccount() int32

func (*Volume) GetAvailabilityArea 

func (x *Volume) GetAvailabilityArea() string

func (*Volume) GetCreatedAt 

func (x *Volume) GetCreatedAt() string

func (*Volume) GetId 

func (x *Volume) GetId() string

func (*Volume) GetMetadata 

func (x *Volume) GetMetadata() map[string][]byte

func (*Volume) GetSize 

func (x *Volume) GetSize() int64

func (*Volume) GetStatus 

func (x *Volume) GetStatus() VolumeStatus

func (*Volume) GetStore 

func (x *Volume) GetStore() string

func (*Volume) GetUpdatedAt 

func (x *Volume) GetUpdatedAt() string

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

func (x *Volume) ProtoReflect() protoreflect.Message

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type VolumeStatus 

type VolumeStatus int32
const (
	VolumeStatus_PENDING   VolumeStatus = 0
	VolumeStatus_CREATING  VolumeStatus = 1
	VolumeStatus_AVAILABLE VolumeStatus = 2
	VolumeStatus_INUSE     VolumeStatus = 3
	VolumeStatus_BACKINGUP VolumeStatus = 4
	VolumeStatus_RESTORING VolumeStatus = 5
	VolumeStatus_RESIZING  VolumeStatus = 6
	VolumeStatus_DELETING  VolumeStatus = 7
	VolumeStatus_DELETED   VolumeStatus = 8
	VolumeStatus_ERROR     VolumeStatus = 99
)

func (VolumeStatus) Descriptor 

func (VolumeStatus) Descriptor() protoreflect.EnumDescriptor

func (VolumeStatus) Enum 

func (x VolumeStatus) Enum() *VolumeStatus

func (VolumeStatus) EnumDescriptor deprecated 

func (VolumeStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use VolumeStatus.Descriptor instead.

func (VolumeStatus) Number 

func (x VolumeStatus) Number() protoreflect.EnumNumber

func (VolumeStatus) String 

func (x VolumeStatus) String() string

func (VolumeStatus) Type 

func (VolumeStatus) Type() protoreflect.EnumType

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.