models

package
v0.0.0-...-71dce46 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2017 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package models is the package containing all the protos used for serializing data for Torus. 

Package models is a generated protocol buffer package.

It is generated from these files:
	rpc.proto
	torus.proto

It has these top-level messages:
	BlockRequest
	BlockResponse
	PutBlockRequest
	PutResponse
	RebalanceCheckRequest
	RebalanceCheckResponse
	INode
	BlockLayer
	Volume
	PeerInfo
	RebalanceInfo
	Ring
	BlockRef
	INodeRef

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTorus = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTorus   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterTorusStorageServer 

func RegisterTorusStorageServer(s *grpc.Server, srv TorusStorageServer)

Types

type BlockLayer 

type BlockLayer struct {
	Type    uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
}

func NewPopulatedBlockLayer 

func NewPopulatedBlockLayer(r randyTorus, easy bool) *BlockLayer

func (*BlockLayer) Descriptor 

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

func (*BlockLayer) Equal 

func (this *BlockLayer) Equal(that interface{}) bool

func (*BlockLayer) GetContent 

func (m *BlockLayer) GetContent() []byte

func (*BlockLayer) GetType 

func (m *BlockLayer) GetType() uint32

func (*BlockLayer) Marshal 

func (m *BlockLayer) Marshal() (dAtA []byte, err error)

func (*BlockLayer) MarshalTo 

func (m *BlockLayer) MarshalTo(dAtA []byte) (int, error)

func (*BlockLayer) ProtoMessage 

func (*BlockLayer) ProtoMessage()

func (*BlockLayer) Reset 

func (m *BlockLayer) Reset()

func (*BlockLayer) Size 

func (m *BlockLayer) Size() (n int)

func (*BlockLayer) String 

func (m *BlockLayer) String() string

func (*BlockLayer) Unmarshal 

func (m *BlockLayer) Unmarshal(dAtA []byte) error

func (*BlockLayer) VerboseEqual 

func (this *BlockLayer) VerboseEqual(that interface{}) error

type BlockRef 

type BlockRef struct {
	Volume uint64 `protobuf:"varint,1,opt,name=volume,proto3" json:"volume,omitempty"`
	INode  uint64 `protobuf:"varint,2,opt,name=inode,proto3" json:"inode,omitempty"`
	Block  uint64 `protobuf:"varint,3,opt,name=block,proto3" json:"block,omitempty"`
}

func NewPopulatedBlockRef 

func NewPopulatedBlockRef(r randyTorus, easy bool) *BlockRef

func (*BlockRef) Descriptor 

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

func (*BlockRef) Equal 

func (this *BlockRef) Equal(that interface{}) bool

func (*BlockRef) GetBlock 

func (m *BlockRef) GetBlock() uint64

func (*BlockRef) GetINode 

func (m *BlockRef) GetINode() uint64

func (*BlockRef) GetVolume 

func (m *BlockRef) GetVolume() uint64

func (*BlockRef) Marshal 

func (m *BlockRef) Marshal() (dAtA []byte, err error)

func (*BlockRef) MarshalTo 

func (m *BlockRef) MarshalTo(dAtA []byte) (int, error)

func (*BlockRef) ProtoMessage 

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset 

func (m *BlockRef) Reset()

func (*BlockRef) Size 

func (m *BlockRef) Size() (n int)

func (*BlockRef) String 

func (m *BlockRef) String() string

func (*BlockRef) Unmarshal 

func (m *BlockRef) Unmarshal(dAtA []byte) error

func (*BlockRef) VerboseEqual 

func (this *BlockRef) VerboseEqual(that interface{}) error

type BlockRequest 

type BlockRequest struct {
	BlockRef *BlockRef `protobuf:"bytes,1,opt,name=block_ref,json=blockRef" json:"block_ref,omitempty"`
}

func NewPopulatedBlockRequest 

func NewPopulatedBlockRequest(r randyRpc, easy bool) *BlockRequest

func (*BlockRequest) Descriptor 

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

func (*BlockRequest) Equal 

func (this *BlockRequest) Equal(that interface{}) bool

func (*BlockRequest) GetBlockRef 

func (m *BlockRequest) GetBlockRef() *BlockRef

func (*BlockRequest) Marshal 

func (m *BlockRequest) Marshal() (dAtA []byte, err error)

func (*BlockRequest) MarshalTo 

func (m *BlockRequest) MarshalTo(dAtA []byte) (int, error)

func (*BlockRequest) ProtoMessage 

func (*BlockRequest) ProtoMessage()

func (*BlockRequest) Reset 

func (m *BlockRequest) Reset()

func (*BlockRequest) Size 

func (m *BlockRequest) Size() (n int)

func (*BlockRequest) String 

func (m *BlockRequest) String() string

func (*BlockRequest) Unmarshal 

func (m *BlockRequest) Unmarshal(dAtA []byte) error

func (*BlockRequest) VerboseEqual 

func (this *BlockRequest) VerboseEqual(that interface{}) error

type BlockResponse 

type BlockResponse struct {
	Ok   bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func NewPopulatedBlockResponse 

func NewPopulatedBlockResponse(r randyRpc, easy bool) *BlockResponse

func (*BlockResponse) Descriptor 

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

func (*BlockResponse) Equal 

func (this *BlockResponse) Equal(that interface{}) bool

func (*BlockResponse) GetData 

func (m *BlockResponse) GetData() []byte

func (*BlockResponse) GetOk 

func (m *BlockResponse) GetOk() bool

func (*BlockResponse) Marshal 

func (m *BlockResponse) Marshal() (dAtA []byte, err error)

func (*BlockResponse) MarshalTo 

func (m *BlockResponse) MarshalTo(dAtA []byte) (int, error)

func (*BlockResponse) ProtoMessage 

func (*BlockResponse) ProtoMessage()

func (*BlockResponse) Reset 

func (m *BlockResponse) Reset()

func (*BlockResponse) Size 

func (m *BlockResponse) Size() (n int)

func (*BlockResponse) String 

func (m *BlockResponse) String() string

func (*BlockResponse) Unmarshal 

func (m *BlockResponse) Unmarshal(dAtA []byte) error

func (*BlockResponse) VerboseEqual 

func (this *BlockResponse) VerboseEqual(that interface{}) error

type INode 

type INode struct {
	Volume   uint64            `protobuf:"varint,1,opt,name=volume,proto3" json:"volume,omitempty"`
	INode    uint64            `protobuf:"varint,2,opt,name=inode,proto3" json:"inode,omitempty"`
	Filesize uint64            `protobuf:"varint,4,opt,name=filesize,proto3" json:"filesize,omitempty"`
	Attrs    map[string]string `` /* 144-byte string literal not displayed */
	Blocks   []*BlockLayer     `protobuf:"bytes,8,rep,name=blocks" json:"blocks,omitempty"`
}

func NewEmptyINode 

func NewEmptyINode() *INode

func NewPopulatedINode 

func NewPopulatedINode(r randyTorus, easy bool) *INode

func (*INode) Descriptor 

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

func (*INode) Equal 

func (this *INode) Equal(that interface{}) bool

func (*INode) GetAttrs 

func (m *INode) GetAttrs() map[string]string

func (*INode) GetBlocks 

func (m *INode) GetBlocks() []*BlockLayer

func (*INode) GetFilesize 

func (m *INode) GetFilesize() uint64

func (*INode) GetINode 

func (m *INode) GetINode() uint64

func (*INode) GetVolume 

func (m *INode) GetVolume() uint64

func (*INode) Marshal 

func (m *INode) Marshal() (dAtA []byte, err error)

func (*INode) MarshalTo 

func (m *INode) MarshalTo(dAtA []byte) (int, error)

func (*INode) ProtoMessage 

func (*INode) ProtoMessage()

func (*INode) Reset 

func (m *INode) Reset()

func (*INode) Size 

func (m *INode) Size() (n int)

func (*INode) String 

func (m *INode) String() string

func (*INode) Unmarshal 

func (m *INode) Unmarshal(dAtA []byte) error

func (*INode) VerboseEqual 

func (this *INode) VerboseEqual(that interface{}) error

type INodeRef 

type INodeRef struct {
	Volume uint64 `protobuf:"varint,1,opt,name=volume,proto3" json:"volume,omitempty"`
	INode  uint64 `protobuf:"varint,2,opt,name=inode,proto3" json:"inode,omitempty"`
}

func NewPopulatedINodeRef 

func NewPopulatedINodeRef(r randyTorus, easy bool) *INodeRef

func (*INodeRef) Descriptor 

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

func (*INodeRef) Equal 

func (this *INodeRef) Equal(that interface{}) bool

func (*INodeRef) GetINode 

func (m *INodeRef) GetINode() uint64

func (*INodeRef) GetVolume 

func (m *INodeRef) GetVolume() uint64

func (*INodeRef) Marshal 

func (m *INodeRef) Marshal() (dAtA []byte, err error)

func (*INodeRef) MarshalTo 

func (m *INodeRef) MarshalTo(dAtA []byte) (int, error)

func (*INodeRef) ProtoMessage 

func (*INodeRef) ProtoMessage()

func (*INodeRef) Reset 

func (m *INodeRef) Reset()

func (*INodeRef) Size 

func (m *INodeRef) Size() (n int)

func (*INodeRef) String 

func (m *INodeRef) String() string

func (*INodeRef) Unmarshal 

func (m *INodeRef) Unmarshal(dAtA []byte) error

func (*INodeRef) VerboseEqual 

func (this *INodeRef) VerboseEqual(that interface{}) error

type PeerInfo 

type PeerInfo struct {
	UUID          string         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Address       string         `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	LastSeen      int64          `protobuf:"varint,3,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	TotalBlocks   uint64         `protobuf:"varint,4,opt,name=total_blocks,json=totalBlocks,proto3" json:"total_blocks,omitempty"`
	UsedBlocks    uint64         `protobuf:"varint,5,opt,name=used_blocks,json=usedBlocks,proto3" json:"used_blocks,omitempty"`
	TimedOut      bool           `protobuf:"varint,6,opt,name=timed_out,json=timedOut,proto3" json:"timed_out,omitempty"`
	RebalanceInfo *RebalanceInfo `protobuf:"bytes,7,opt,name=rebalance_info,json=rebalanceInfo" json:"rebalance_info,omitempty"`
	// ProtocolVersion is set by each peer to know if we're out of date or if a
	// protocol migration has occured.
	ProtocolVersion uint64 `protobuf:"varint,8,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
}

func NewPopulatedPeerInfo 

func NewPopulatedPeerInfo(r randyTorus, easy bool) *PeerInfo

func (*PeerInfo) Descriptor 

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

func (*PeerInfo) Equal 

func (this *PeerInfo) Equal(that interface{}) bool

func (*PeerInfo) GetAddress 

func (m *PeerInfo) GetAddress() string

func (*PeerInfo) GetLastSeen 

func (m *PeerInfo) GetLastSeen() int64

func (*PeerInfo) GetProtocolVersion 

func (m *PeerInfo) GetProtocolVersion() uint64

func (*PeerInfo) GetRebalanceInfo 

func (m *PeerInfo) GetRebalanceInfo() *RebalanceInfo

func (*PeerInfo) GetTimedOut 

func (m *PeerInfo) GetTimedOut() bool

func (*PeerInfo) GetTotalBlocks 

func (m *PeerInfo) GetTotalBlocks() uint64

func (*PeerInfo) GetUUID 

func (m *PeerInfo) GetUUID() string

func (*PeerInfo) GetUsedBlocks 

func (m *PeerInfo) GetUsedBlocks() uint64

func (*PeerInfo) Marshal 

func (m *PeerInfo) Marshal() (dAtA []byte, err error)

func (*PeerInfo) MarshalTo 

func (m *PeerInfo) MarshalTo(dAtA []byte) (int, error)

func (*PeerInfo) ProtoMessage 

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset 

func (m *PeerInfo) Reset()

func (*PeerInfo) Size 

func (m *PeerInfo) Size() (n int)

func (*PeerInfo) String 

func (m *PeerInfo) String() string

func (*PeerInfo) Unmarshal 

func (m *PeerInfo) Unmarshal(dAtA []byte) error

func (*PeerInfo) VerboseEqual 

func (this *PeerInfo) VerboseEqual(that interface{}) error

type PutBlockRequest 

type PutBlockRequest struct {
	Refs   []*BlockRef `protobuf:"bytes,1,rep,name=refs" json:"refs,omitempty"`
	Blocks [][]byte    `protobuf:"bytes,2,rep,name=blocks" json:"blocks,omitempty"`
}

func NewPopulatedPutBlockRequest 

func NewPopulatedPutBlockRequest(r randyRpc, easy bool) *PutBlockRequest

func (*PutBlockRequest) Descriptor 

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

func (*PutBlockRequest) Equal 

func (this *PutBlockRequest) Equal(that interface{}) bool

func (*PutBlockRequest) GetBlocks 

func (m *PutBlockRequest) GetBlocks() [][]byte

func (*PutBlockRequest) GetRefs 

func (m *PutBlockRequest) GetRefs() []*BlockRef

func (*PutBlockRequest) Marshal 

func (m *PutBlockRequest) Marshal() (dAtA []byte, err error)

func (*PutBlockRequest) MarshalTo 

func (m *PutBlockRequest) MarshalTo(dAtA []byte) (int, error)

func (*PutBlockRequest) ProtoMessage 

func (*PutBlockRequest) ProtoMessage()

func (*PutBlockRequest) Reset 

func (m *PutBlockRequest) Reset()

func (*PutBlockRequest) Size 

func (m *PutBlockRequest) Size() (n int)

func (*PutBlockRequest) String 

func (m *PutBlockRequest) String() string

func (*PutBlockRequest) Unmarshal 

func (m *PutBlockRequest) Unmarshal(dAtA []byte) error

func (*PutBlockRequest) VerboseEqual 

func (this *PutBlockRequest) VerboseEqual(that interface{}) error

type PutResponse 

type PutResponse struct {
	Ok  bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Err string `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
}

func NewPopulatedPutResponse 

func NewPopulatedPutResponse(r randyRpc, easy bool) *PutResponse

func (*PutResponse) Descriptor 

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

func (*PutResponse) Equal 

func (this *PutResponse) Equal(that interface{}) bool

func (*PutResponse) GetErr 

func (m *PutResponse) GetErr() string

func (*PutResponse) GetOk 

func (m *PutResponse) GetOk() bool

func (*PutResponse) Marshal 

func (m *PutResponse) Marshal() (dAtA []byte, err error)

func (*PutResponse) MarshalTo 

func (m *PutResponse) MarshalTo(dAtA []byte) (int, error)

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) Size 

func (m *PutResponse) Size() (n int)

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal 

func (m *PutResponse) Unmarshal(dAtA []byte) error

func (*PutResponse) VerboseEqual 

func (this *PutResponse) VerboseEqual(that interface{}) error

type RebalanceCheckRequest 

type RebalanceCheckRequest struct {
	BlockRefs []*BlockRef `protobuf:"bytes,1,rep,name=block_refs,json=blockRefs" json:"block_refs,omitempty"`
}

func NewPopulatedRebalanceCheckRequest 

func NewPopulatedRebalanceCheckRequest(r randyRpc, easy bool) *RebalanceCheckRequest

func (*RebalanceCheckRequest) Descriptor 

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

func (*RebalanceCheckRequest) Equal 

func (this *RebalanceCheckRequest) Equal(that interface{}) bool

func (*RebalanceCheckRequest) GetBlockRefs 

func (m *RebalanceCheckRequest) GetBlockRefs() []*BlockRef

func (*RebalanceCheckRequest) Marshal 

func (m *RebalanceCheckRequest) Marshal() (dAtA []byte, err error)

func (*RebalanceCheckRequest) MarshalTo 

func (m *RebalanceCheckRequest) MarshalTo(dAtA []byte) (int, error)

func (*RebalanceCheckRequest) ProtoMessage 

func (*RebalanceCheckRequest) ProtoMessage()

func (*RebalanceCheckRequest) Reset 

func (m *RebalanceCheckRequest) Reset()

func (*RebalanceCheckRequest) Size 

func (m *RebalanceCheckRequest) Size() (n int)

func (*RebalanceCheckRequest) String 

func (m *RebalanceCheckRequest) String() string

func (*RebalanceCheckRequest) Unmarshal 

func (m *RebalanceCheckRequest) Unmarshal(dAtA []byte) error

func (*RebalanceCheckRequest) VerboseEqual 

func (this *RebalanceCheckRequest) VerboseEqual(that interface{}) error

type RebalanceCheckResponse 

type RebalanceCheckResponse struct {
	Valid  []bool `protobuf:"varint,1,rep,packed,name=valid" json:"valid,omitempty"`
	Status int32  `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
}

func NewPopulatedRebalanceCheckResponse 

func NewPopulatedRebalanceCheckResponse(r randyRpc, easy bool) *RebalanceCheckResponse

func (*RebalanceCheckResponse) Descriptor 

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

func (*RebalanceCheckResponse) Equal 

func (this *RebalanceCheckResponse) Equal(that interface{}) bool

func (*RebalanceCheckResponse) GetStatus 

func (m *RebalanceCheckResponse) GetStatus() int32

func (*RebalanceCheckResponse) GetValid 

func (m *RebalanceCheckResponse) GetValid() []bool

func (*RebalanceCheckResponse) Marshal 

func (m *RebalanceCheckResponse) Marshal() (dAtA []byte, err error)

func (*RebalanceCheckResponse) MarshalTo 

func (m *RebalanceCheckResponse) MarshalTo(dAtA []byte) (int, error)

func (*RebalanceCheckResponse) ProtoMessage 

func (*RebalanceCheckResponse) ProtoMessage()

func (*RebalanceCheckResponse) Reset 

func (m *RebalanceCheckResponse) Reset()

func (*RebalanceCheckResponse) Size 

func (m *RebalanceCheckResponse) Size() (n int)

func (*RebalanceCheckResponse) String 

func (m *RebalanceCheckResponse) String() string

func (*RebalanceCheckResponse) Unmarshal 

func (m *RebalanceCheckResponse) Unmarshal(dAtA []byte) error

func (*RebalanceCheckResponse) VerboseEqual 

func (this *RebalanceCheckResponse) VerboseEqual(that interface{}) error

type RebalanceInfo 

type RebalanceInfo struct {
	LastRebalanceFinish int64  `protobuf:"varint,1,opt,name=last_rebalance_finish,json=lastRebalanceFinish,proto3" json:"last_rebalance_finish,omitempty"`
	LastRebalanceBlocks uint64 `protobuf:"varint,2,opt,name=last_rebalance_blocks,json=lastRebalanceBlocks,proto3" json:"last_rebalance_blocks,omitempty"`
	Rebalancing         bool   `protobuf:"varint,3,opt,name=rebalancing,proto3" json:"rebalancing,omitempty"`
}

func NewPopulatedRebalanceInfo 

func NewPopulatedRebalanceInfo(r randyTorus, easy bool) *RebalanceInfo

func (*RebalanceInfo) Descriptor 

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

func (*RebalanceInfo) Equal 

func (this *RebalanceInfo) Equal(that interface{}) bool

func (*RebalanceInfo) GetLastRebalanceBlocks 

func (m *RebalanceInfo) GetLastRebalanceBlocks() uint64

func (*RebalanceInfo) GetLastRebalanceFinish 

func (m *RebalanceInfo) GetLastRebalanceFinish() int64

func (*RebalanceInfo) GetRebalancing 

func (m *RebalanceInfo) GetRebalancing() bool

func (*RebalanceInfo) Marshal 

func (m *RebalanceInfo) Marshal() (dAtA []byte, err error)

func (*RebalanceInfo) MarshalTo 

func (m *RebalanceInfo) MarshalTo(dAtA []byte) (int, error)

func (*RebalanceInfo) ProtoMessage 

func (*RebalanceInfo) ProtoMessage()

func (*RebalanceInfo) Reset 

func (m *RebalanceInfo) Reset()

func (*RebalanceInfo) Size 

func (m *RebalanceInfo) Size() (n int)

func (*RebalanceInfo) String 

func (m *RebalanceInfo) String() string

func (*RebalanceInfo) Unmarshal 

func (m *RebalanceInfo) Unmarshal(dAtA []byte) error

func (*RebalanceInfo) VerboseEqual 

func (this *RebalanceInfo) VerboseEqual(that interface{}) error

type Ring 

type Ring struct {
	Type              uint32            `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Version           uint32            `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	ReplicationFactor uint32            `protobuf:"varint,3,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	Peers             []*PeerInfo       `protobuf:"bytes,4,rep,name=peers" json:"peers,omitempty"`
	Attrs             map[string][]byte `` /* 144-byte string literal not displayed */
}

func NewPopulatedRing 

func NewPopulatedRing(r randyTorus, easy bool) *Ring

func (*Ring) Descriptor 

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

func (*Ring) Equal 

func (this *Ring) Equal(that interface{}) bool

func (*Ring) GetAttrs 

func (m *Ring) GetAttrs() map[string][]byte

func (*Ring) GetPeers 

func (m *Ring) GetPeers() []*PeerInfo

func (*Ring) GetReplicationFactor 

func (m *Ring) GetReplicationFactor() uint32

func (*Ring) GetType 

func (m *Ring) GetType() uint32

func (*Ring) GetVersion 

func (m *Ring) GetVersion() uint32

func (*Ring) Marshal 

func (m *Ring) Marshal() (dAtA []byte, err error)

func (*Ring) MarshalTo 

func (m *Ring) MarshalTo(dAtA []byte) (int, error)

func (*Ring) ProtoMessage 

func (*Ring) ProtoMessage()

func (*Ring) Reset 

func (m *Ring) Reset()

func (*Ring) Size 

func (m *Ring) Size() (n int)

func (*Ring) String 

func (m *Ring) String() string

func (*Ring) Unmarshal 

func (m *Ring) Unmarshal(dAtA []byte) error

func (*Ring) VerboseEqual 

func (this *Ring) VerboseEqual(that interface{}) error

type TorusStorageClient 

type TorusStorageClient interface {
	Block(ctx context.Context, in *BlockRequest, opts ...grpc.CallOption) (*BlockResponse, error)
	PutBlock(ctx context.Context, in *PutBlockRequest, opts ...grpc.CallOption) (*PutResponse, error)
	RebalanceCheck(ctx context.Context, in *RebalanceCheckRequest, opts ...grpc.CallOption) (*RebalanceCheckResponse, error)
}

func NewTorusStorageClient 

func NewTorusStorageClient(cc *grpc.ClientConn) TorusStorageClient

type TorusStorageServer 

type TorusStorageServer interface {
	Block(context.Context, *BlockRequest) (*BlockResponse, error)
	PutBlock(context.Context, *PutBlockRequest) (*PutResponse, error)
	RebalanceCheck(context.Context, *RebalanceCheckRequest) (*RebalanceCheckResponse, error)
}

type Volume 

type Volume struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id   uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// TODO(barakmich): Respect sizes for FILE volumes.
	MaxBytes uint64 `protobuf:"varint,4,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
}

func NewPopulatedVolume 

func NewPopulatedVolume(r randyTorus, easy bool) *Volume

func (*Volume) Descriptor 

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

func (*Volume) Equal 

func (this *Volume) Equal(that interface{}) bool

func (*Volume) GetId 

func (m *Volume) GetId() uint64

func (*Volume) GetMaxBytes 

func (m *Volume) GetMaxBytes() uint64

func (*Volume) GetName 

func (m *Volume) GetName() string

func (*Volume) GetType 

func (m *Volume) GetType() string

func (*Volume) Marshal 

func (m *Volume) Marshal() (dAtA []byte, err error)

func (*Volume) MarshalTo 

func (m *Volume) MarshalTo(dAtA []byte) (int, error)

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) Size 

func (m *Volume) Size() (n int)

func (*Volume) String 

func (m *Volume) String() string

func (*Volume) Unmarshal 

func (m *Volume) Unmarshal(dAtA []byte) error

func (*Volume) VerboseEqual 

func (this *Volume) VerboseEqual(that interface{}) 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.