Versions in this module Expand all Collapse all v0 v0.1.2 Sep 15, 2016 v0.1.1 Jun 16, 2016 Changes in this version type PeerInfo + ProtocolVersion uint64 v0.1.1-fish Jul 24, 2016 v0.1.0 Jun 1, 2016 Changes in this version + var ErrIntOverflowTorus = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTorus = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterTorusStorageServer(s *grpc.Server, srv TorusStorageServer) + type TorusStorageClient interface + Block func(ctx context.Context, in *BlockRequest, opts ...grpc.CallOption) (*BlockResponse, error) + PutBlock func(ctx context.Context, in *PutBlockRequest, opts ...grpc.CallOption) (*PutResponse, error) + RebalanceCheck func(ctx context.Context, in *RebalanceCheckRequest, opts ...grpc.CallOption) (*RebalanceCheckResponse, error) + func NewTorusStorageClient(cc *grpc.ClientConn) TorusStorageClient + type TorusStorageServer interface + Block func(context.Context, *BlockRequest) (*BlockResponse, error) + PutBlock func(context.Context, *PutBlockRequest) (*PutResponse, error) + RebalanceCheck func(context.Context, *RebalanceCheckRequest) (*RebalanceCheckResponse, error) v0.0.1 Apr 27, 2016 Changes in this version + var ErrIntOverflowAgro = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthAgro = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterAgroStorageServer(s *grpc.Server, srv AgroStorageServer) + type AgroStorageClient interface + Block func(ctx context.Context, in *BlockRequest, opts ...grpc.CallOption) (*BlockResponse, error) + PutBlock func(ctx context.Context, in *PutBlockRequest, opts ...grpc.CallOption) (*PutResponse, error) + RebalanceCheck func(ctx context.Context, in *RebalanceCheckRequest, opts ...grpc.CallOption) (*RebalanceCheckResponse, error) + func NewAgroStorageClient(cc *grpc.ClientConn) AgroStorageClient + type AgroStorageServer interface + Block func(context.Context, *BlockRequest) (*BlockResponse, error) + PutBlock func(context.Context, *PutBlockRequest) (*PutResponse, error) + RebalanceCheck func(context.Context, *RebalanceCheckRequest) (*RebalanceCheckResponse, error) + type BlockLayer struct + Content []byte + Type uint32 + func NewPopulatedBlockLayer(r randyAgro, easy bool) *BlockLayer + func (*BlockLayer) Descriptor() ([]byte, []int) + func (*BlockLayer) ProtoMessage() + func (m *BlockLayer) Marshal() (data []byte, err error) + func (m *BlockLayer) MarshalTo(data []byte) (int, error) + func (m *BlockLayer) Reset() + func (m *BlockLayer) Size() (n int) + func (m *BlockLayer) String() string + func (m *BlockLayer) Unmarshal(data []byte) error + func (this *BlockLayer) Equal(that interface{}) bool + func (this *BlockLayer) VerboseEqual(that interface{}) error + type BlockRef struct + Block uint64 + INode uint64 + Volume uint64 + func NewPopulatedBlockRef(r randyAgro, easy bool) *BlockRef + func (*BlockRef) Descriptor() ([]byte, []int) + func (*BlockRef) ProtoMessage() + func (m *BlockRef) Marshal() (data []byte, err error) + func (m *BlockRef) MarshalTo(data []byte) (int, error) + func (m *BlockRef) Reset() + func (m *BlockRef) Size() (n int) + func (m *BlockRef) String() string + func (m *BlockRef) Unmarshal(data []byte) error + func (this *BlockRef) Equal(that interface{}) bool + func (this *BlockRef) VerboseEqual(that interface{}) error + type BlockRequest struct + BlockRef *BlockRef + func NewPopulatedBlockRequest(r randyRpc, easy bool) *BlockRequest + func (*BlockRequest) Descriptor() ([]byte, []int) + func (*BlockRequest) ProtoMessage() + func (m *BlockRequest) GetBlockRef() *BlockRef + func (m *BlockRequest) Marshal() (data []byte, err error) + func (m *BlockRequest) MarshalTo(data []byte) (int, error) + func (m *BlockRequest) Reset() + func (m *BlockRequest) Size() (n int) + func (m *BlockRequest) String() string + func (m *BlockRequest) Unmarshal(data []byte) error + func (this *BlockRequest) Equal(that interface{}) bool + func (this *BlockRequest) VerboseEqual(that interface{}) error + type BlockResponse struct + Data []byte + Ok bool + func NewPopulatedBlockResponse(r randyRpc, easy bool) *BlockResponse + func (*BlockResponse) Descriptor() ([]byte, []int) + func (*BlockResponse) ProtoMessage() + func (m *BlockResponse) Marshal() (data []byte, err error) + func (m *BlockResponse) MarshalTo(data []byte) (int, error) + func (m *BlockResponse) Reset() + func (m *BlockResponse) Size() (n int) + func (m *BlockResponse) String() string + func (m *BlockResponse) Unmarshal(data []byte) error + func (this *BlockResponse) Equal(that interface{}) bool + func (this *BlockResponse) VerboseEqual(that interface{}) error + type INode struct + Attrs map[string]string + Blocks []*BlockLayer + Filesize uint64 + INode uint64 + Volume uint64 + func NewEmptyINode() *INode + func NewPopulatedINode(r randyAgro, easy bool) *INode + func (*INode) Descriptor() ([]byte, []int) + func (*INode) ProtoMessage() + func (m *INode) GetAttrs() map[string]string + func (m *INode) GetBlocks() []*BlockLayer + func (m *INode) Marshal() (data []byte, err error) + func (m *INode) MarshalTo(data []byte) (int, error) + func (m *INode) Reset() + func (m *INode) Size() (n int) + func (m *INode) String() string + func (m *INode) Unmarshal(data []byte) error + func (this *INode) Equal(that interface{}) bool + func (this *INode) VerboseEqual(that interface{}) error + type INodeRef struct + INode uint64 + Volume uint64 + func NewPopulatedINodeRef(r randyAgro, easy bool) *INodeRef + func (*INodeRef) Descriptor() ([]byte, []int) + func (*INodeRef) ProtoMessage() + func (m *INodeRef) Marshal() (data []byte, err error) + func (m *INodeRef) MarshalTo(data []byte) (int, error) + func (m *INodeRef) Reset() + func (m *INodeRef) Size() (n int) + func (m *INodeRef) String() string + func (m *INodeRef) Unmarshal(data []byte) error + func (this *INodeRef) Equal(that interface{}) bool + func (this *INodeRef) VerboseEqual(that interface{}) error + type PeerInfo struct + Address string + LastSeen int64 + RebalanceInfo *RebalanceInfo + TimedOut bool + TotalBlocks uint64 + UUID string + UsedBlocks uint64 + func NewPopulatedPeerInfo(r randyAgro, easy bool) *PeerInfo + func (*PeerInfo) Descriptor() ([]byte, []int) + func (*PeerInfo) ProtoMessage() + func (m *PeerInfo) GetRebalanceInfo() *RebalanceInfo + func (m *PeerInfo) Marshal() (data []byte, err error) + func (m *PeerInfo) MarshalTo(data []byte) (int, error) + func (m *PeerInfo) Reset() + func (m *PeerInfo) Size() (n int) + func (m *PeerInfo) String() string + func (m *PeerInfo) Unmarshal(data []byte) error + func (this *PeerInfo) Equal(that interface{}) bool + func (this *PeerInfo) VerboseEqual(that interface{}) error + type PutBlockRequest struct + Blocks [][]byte + Refs []*BlockRef + func NewPopulatedPutBlockRequest(r randyRpc, easy bool) *PutBlockRequest + func (*PutBlockRequest) Descriptor() ([]byte, []int) + func (*PutBlockRequest) ProtoMessage() + func (m *PutBlockRequest) GetRefs() []*BlockRef + func (m *PutBlockRequest) Marshal() (data []byte, err error) + func (m *PutBlockRequest) MarshalTo(data []byte) (int, error) + func (m *PutBlockRequest) Reset() + func (m *PutBlockRequest) Size() (n int) + func (m *PutBlockRequest) String() string + func (m *PutBlockRequest) Unmarshal(data []byte) error + func (this *PutBlockRequest) Equal(that interface{}) bool + func (this *PutBlockRequest) VerboseEqual(that interface{}) error + type PutResponse struct + Err string + Ok bool + func NewPopulatedPutResponse(r randyRpc, easy bool) *PutResponse + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) Marshal() (data []byte, err error) + func (m *PutResponse) MarshalTo(data []byte) (int, error) + func (m *PutResponse) Reset() + func (m *PutResponse) Size() (n int) + func (m *PutResponse) String() string + func (m *PutResponse) Unmarshal(data []byte) error + func (this *PutResponse) Equal(that interface{}) bool + func (this *PutResponse) VerboseEqual(that interface{}) error + type RebalanceCheckRequest struct + BlockRefs []*BlockRef + func NewPopulatedRebalanceCheckRequest(r randyRpc, easy bool) *RebalanceCheckRequest + func (*RebalanceCheckRequest) Descriptor() ([]byte, []int) + func (*RebalanceCheckRequest) ProtoMessage() + func (m *RebalanceCheckRequest) GetBlockRefs() []*BlockRef + func (m *RebalanceCheckRequest) Marshal() (data []byte, err error) + func (m *RebalanceCheckRequest) MarshalTo(data []byte) (int, error) + func (m *RebalanceCheckRequest) Reset() + func (m *RebalanceCheckRequest) Size() (n int) + func (m *RebalanceCheckRequest) String() string + func (m *RebalanceCheckRequest) Unmarshal(data []byte) error + func (this *RebalanceCheckRequest) Equal(that interface{}) bool + func (this *RebalanceCheckRequest) VerboseEqual(that interface{}) error + type RebalanceCheckResponse struct + Status int32 + Valid []bool + func NewPopulatedRebalanceCheckResponse(r randyRpc, easy bool) *RebalanceCheckResponse + func (*RebalanceCheckResponse) Descriptor() ([]byte, []int) + func (*RebalanceCheckResponse) ProtoMessage() + func (m *RebalanceCheckResponse) Marshal() (data []byte, err error) + func (m *RebalanceCheckResponse) MarshalTo(data []byte) (int, error) + func (m *RebalanceCheckResponse) Reset() + func (m *RebalanceCheckResponse) Size() (n int) + func (m *RebalanceCheckResponse) String() string + func (m *RebalanceCheckResponse) Unmarshal(data []byte) error + func (this *RebalanceCheckResponse) Equal(that interface{}) bool + func (this *RebalanceCheckResponse) VerboseEqual(that interface{}) error + type RebalanceInfo struct + LastRebalanceBlocks uint64 + LastRebalanceFinish int64 + Rebalancing bool + func NewPopulatedRebalanceInfo(r randyAgro, easy bool) *RebalanceInfo + func (*RebalanceInfo) Descriptor() ([]byte, []int) + func (*RebalanceInfo) ProtoMessage() + func (m *RebalanceInfo) Marshal() (data []byte, err error) + func (m *RebalanceInfo) MarshalTo(data []byte) (int, error) + func (m *RebalanceInfo) Reset() + func (m *RebalanceInfo) Size() (n int) + func (m *RebalanceInfo) String() string + func (m *RebalanceInfo) Unmarshal(data []byte) error + func (this *RebalanceInfo) Equal(that interface{}) bool + func (this *RebalanceInfo) VerboseEqual(that interface{}) error + type Ring struct + Attrs map[string][]byte + Peers []*PeerInfo + ReplicationFactor uint32 + Type uint32 + Version uint32 + func NewPopulatedRing(r randyAgro, easy bool) *Ring + func (*Ring) Descriptor() ([]byte, []int) + func (*Ring) ProtoMessage() + func (m *Ring) GetAttrs() map[string][]byte + func (m *Ring) GetPeers() []*PeerInfo + func (m *Ring) Marshal() (data []byte, err error) + func (m *Ring) MarshalTo(data []byte) (int, error) + func (m *Ring) Reset() + func (m *Ring) Size() (n int) + func (m *Ring) String() string + func (m *Ring) Unmarshal(data []byte) error + func (this *Ring) Equal(that interface{}) bool + func (this *Ring) VerboseEqual(that interface{}) error + type Volume struct + Id uint64 + MaxBytes uint64 + Name string + Type string + func NewPopulatedVolume(r randyAgro, easy bool) *Volume + func (*Volume) Descriptor() ([]byte, []int) + func (*Volume) ProtoMessage() + func (m *Volume) Marshal() (data []byte, err error) + func (m *Volume) MarshalTo(data []byte) (int, error) + func (m *Volume) Reset() + func (m *Volume) Size() (n int) + func (m *Volume) String() string + func (m *Volume) Unmarshal(data []byte) error + func (this *Volume) Equal(that interface{}) bool + func (this *Volume) VerboseEqual(that interface{}) error
Go to main page