v1

package
v0.2.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDDRPv1Server 

func RegisterDDRPv1Server(s *grpc.Server, srv DDRPv1Server)

Types

type AddPeerReq 

type AddPeerReq struct {
	PeerID               []byte   `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	VerifyPeerID         bool     `protobuf:"varint,3,opt,name=verifyPeerID,proto3" json:"verifyPeerID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddPeerReq) Descriptor 

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

func (*AddPeerReq) GetIp 

func (m *AddPeerReq) GetIp() string

func (*AddPeerReq) GetPeerID 

func (m *AddPeerReq) GetPeerID() []byte

func (*AddPeerReq) GetVerifyPeerID 

func (m *AddPeerReq) GetVerifyPeerID() bool

func (*AddPeerReq) ProtoMessage 

func (*AddPeerReq) ProtoMessage()

func (*AddPeerReq) Reset 

func (m *AddPeerReq) Reset()

func (*AddPeerReq) String 

func (m *AddPeerReq) String() string

func (*AddPeerReq) XXX_DiscardUnknown 

func (m *AddPeerReq) XXX_DiscardUnknown()

func (*AddPeerReq) XXX_Marshal 

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

func (*AddPeerReq) XXX_Merge 

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

func (*AddPeerReq) XXX_Size 

func (m *AddPeerReq) XXX_Size() int

func (*AddPeerReq) XXX_Unmarshal 

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

type BanPeerReq 

type BanPeerReq struct {
	Ip                   string   `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	DurationMS           uint32   `protobuf:"varint,2,opt,name=durationMS,proto3" json:"durationMS,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BanPeerReq) Descriptor 

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

func (*BanPeerReq) GetDurationMS 

func (m *BanPeerReq) GetDurationMS() uint32

func (*BanPeerReq) GetIp 

func (m *BanPeerReq) GetIp() string

func (*BanPeerReq) ProtoMessage 

func (*BanPeerReq) ProtoMessage()

func (*BanPeerReq) Reset 

func (m *BanPeerReq) Reset()

func (*BanPeerReq) String 

func (m *BanPeerReq) String() string

func (*BanPeerReq) XXX_DiscardUnknown 

func (m *BanPeerReq) XXX_DiscardUnknown()

func (*BanPeerReq) XXX_Marshal 

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

func (*BanPeerReq) XXX_Merge 

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

func (*BanPeerReq) XXX_Size 

func (m *BanPeerReq) XXX_Size() int

func (*BanPeerReq) XXX_Unmarshal 

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

type BlobInfoReq 

type BlobInfoReq 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 (*BlobInfoReq) Descriptor 

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

func (*BlobInfoReq) GetName 

func (m *BlobInfoReq) GetName() string

func (*BlobInfoReq) ProtoMessage 

func (*BlobInfoReq) ProtoMessage()

func (*BlobInfoReq) Reset 

func (m *BlobInfoReq) Reset()

func (*BlobInfoReq) String 

func (m *BlobInfoReq) String() string

func (*BlobInfoReq) XXX_DiscardUnknown 

func (m *BlobInfoReq) XXX_DiscardUnknown()

func (*BlobInfoReq) XXX_Marshal 

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

func (*BlobInfoReq) XXX_Merge 

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

func (*BlobInfoReq) XXX_Size 

func (m *BlobInfoReq) XXX_Size() int

func (*BlobInfoReq) XXX_Unmarshal 

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

type BlobInfoRes 

type BlobInfoRes struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PublicKey            []byte   `protobuf:"bytes,2,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	ImportHeight         uint32   `protobuf:"varint,3,opt,name=importHeight,proto3" json:"importHeight,omitempty"`
	Timestamp            uint64   `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	MerkleRoot           []byte   `protobuf:"bytes,5,opt,name=merkleRoot,proto3" json:"merkleRoot,omitempty"`
	ReservedRoot         []byte   `protobuf:"bytes,6,opt,name=reservedRoot,proto3" json:"reservedRoot,omitempty"`
	ReceivedAt           uint64   `protobuf:"varint,7,opt,name=receivedAt,proto3" json:"receivedAt,omitempty"`
	Signature            []byte   `protobuf:"bytes,8,opt,name=signature,proto3" json:"signature,omitempty"`
	Timebank             uint32   `protobuf:"varint,9,opt,name=timebank,proto3" json:"timebank,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlobInfoRes) Descriptor 

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

func (*BlobInfoRes) GetImportHeight 

func (m *BlobInfoRes) GetImportHeight() uint32

func (*BlobInfoRes) GetMerkleRoot 

func (m *BlobInfoRes) GetMerkleRoot() []byte

func (*BlobInfoRes) GetName 

func (m *BlobInfoRes) GetName() string

func (*BlobInfoRes) GetPublicKey 

func (m *BlobInfoRes) GetPublicKey() []byte

func (*BlobInfoRes) GetReceivedAt 

func (m *BlobInfoRes) GetReceivedAt() uint64

func (*BlobInfoRes) GetReservedRoot 

func (m *BlobInfoRes) GetReservedRoot() []byte

func (*BlobInfoRes) GetSignature 

func (m *BlobInfoRes) GetSignature() []byte

func (*BlobInfoRes) GetTimebank 

func (m *BlobInfoRes) GetTimebank() uint32

func (*BlobInfoRes) GetTimestamp 

func (m *BlobInfoRes) GetTimestamp() uint64

func (*BlobInfoRes) ProtoMessage 

func (*BlobInfoRes) ProtoMessage()

func (*BlobInfoRes) Reset 

func (m *BlobInfoRes) Reset()

func (*BlobInfoRes) String 

func (m *BlobInfoRes) String() string

func (*BlobInfoRes) XXX_DiscardUnknown 

func (m *BlobInfoRes) XXX_DiscardUnknown()

func (*BlobInfoRes) XXX_Marshal 

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

func (*BlobInfoRes) XXX_Merge 

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

func (*BlobInfoRes) XXX_Size 

func (m *BlobInfoRes) XXX_Size() int

func (*BlobInfoRes) XXX_Unmarshal 

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

type CheckoutReq 

type CheckoutReq 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 (*CheckoutReq) Descriptor 

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

func (*CheckoutReq) GetName 

func (m *CheckoutReq) GetName() string

func (*CheckoutReq) ProtoMessage 

func (*CheckoutReq) ProtoMessage()

func (*CheckoutReq) Reset 

func (m *CheckoutReq) Reset()

func (*CheckoutReq) String 

func (m *CheckoutReq) String() string

func (*CheckoutReq) XXX_DiscardUnknown 

func (m *CheckoutReq) XXX_DiscardUnknown()

func (*CheckoutReq) XXX_Marshal 

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

func (*CheckoutReq) XXX_Merge 

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

func (*CheckoutReq) XXX_Size 

func (m *CheckoutReq) XXX_Size() int

func (*CheckoutReq) XXX_Unmarshal 

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

type CheckoutRes 

type CheckoutRes struct {
	TxID                 uint32   `protobuf:"varint,1,opt,name=txID,proto3" json:"txID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckoutRes) Descriptor 

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

func (*CheckoutRes) GetTxID 

func (m *CheckoutRes) GetTxID() uint32

func (*CheckoutRes) ProtoMessage 

func (*CheckoutRes) ProtoMessage()

func (*CheckoutRes) Reset 

func (m *CheckoutRes) Reset()

func (*CheckoutRes) String 

func (m *CheckoutRes) String() string

func (*CheckoutRes) XXX_DiscardUnknown 

func (m *CheckoutRes) XXX_DiscardUnknown()

func (*CheckoutRes) XXX_Marshal 

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

func (*CheckoutRes) XXX_Merge 

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

func (*CheckoutRes) XXX_Size 

func (m *CheckoutRes) XXX_Size() int

func (*CheckoutRes) XXX_Unmarshal 

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

type CommitReq 

type CommitReq struct {
	TxID                 uint32   `protobuf:"varint,1,opt,name=txID,proto3" json:"txID,omitempty"`
	Timestamp            uint64   `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Signature            []byte   `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	Broadcast            bool     `protobuf:"varint,4,opt,name=broadcast,proto3" json:"broadcast,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommitReq) Descriptor 

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

func (*CommitReq) GetBroadcast 

func (m *CommitReq) GetBroadcast() bool

func (*CommitReq) GetSignature 

func (m *CommitReq) GetSignature() []byte

func (*CommitReq) GetTimestamp 

func (m *CommitReq) GetTimestamp() uint64

func (*CommitReq) GetTxID 

func (m *CommitReq) GetTxID() uint32

func (*CommitReq) ProtoMessage 

func (*CommitReq) ProtoMessage()

func (*CommitReq) Reset 

func (m *CommitReq) Reset()

func (*CommitReq) String 

func (m *CommitReq) String() string

func (*CommitReq) XXX_DiscardUnknown 

func (m *CommitReq) XXX_DiscardUnknown()

func (*CommitReq) XXX_Marshal 

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

func (*CommitReq) XXX_Merge 

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

func (*CommitReq) XXX_Size 

func (m *CommitReq) XXX_Size() int

func (*CommitReq) XXX_Unmarshal 

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

type CommitRes 

type CommitRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommitRes) Descriptor 

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

func (*CommitRes) ProtoMessage 

func (*CommitRes) ProtoMessage()

func (*CommitRes) Reset 

func (m *CommitRes) Reset()

func (*CommitRes) String 

func (m *CommitRes) String() string

func (*CommitRes) XXX_DiscardUnknown 

func (m *CommitRes) XXX_DiscardUnknown()

func (*CommitRes) XXX_Marshal 

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

func (*CommitRes) XXX_Merge 

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

func (*CommitRes) XXX_Size 

func (m *CommitRes) XXX_Size() int

func (*CommitRes) XXX_Unmarshal 

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

type DDRPv1Client 

type DDRPv1Client interface {
	GetStatus(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetStatusRes, error)
	AddPeer(ctx context.Context, in *AddPeerReq, opts ...grpc.CallOption) (*Empty, error)
	BanPeer(ctx context.Context, in *BanPeerReq, opts ...grpc.CallOption) (*Empty, error)
	UnbanPeer(ctx context.Context, in *UnbanPeerReq, opts ...grpc.CallOption) (*Empty, error)
	ListPeers(ctx context.Context, in *ListPeersReq, opts ...grpc.CallOption) (DDRPv1_ListPeersClient, error)
	Checkout(ctx context.Context, in *CheckoutReq, opts ...grpc.CallOption) (*CheckoutRes, error)
	WriteAt(ctx context.Context, in *WriteAtReq, opts ...grpc.CallOption) (*WriteAtRes, error)
	Truncate(ctx context.Context, in *TruncateReq, opts ...grpc.CallOption) (*Empty, error)
	PreCommit(ctx context.Context, in *PreCommitReq, opts ...grpc.CallOption) (*PreCommitRes, error)
	Commit(ctx context.Context, in *CommitReq, opts ...grpc.CallOption) (*CommitRes, error)
	ReadAt(ctx context.Context, in *ReadAtReq, opts ...grpc.CallOption) (*ReadAtRes, error)
	GetBlobInfo(ctx context.Context, in *BlobInfoReq, opts ...grpc.CallOption) (*BlobInfoRes, error)
	ListBlobInfo(ctx context.Context, in *ListBlobInfoReq, opts ...grpc.CallOption) (DDRPv1_ListBlobInfoClient, error)
	SendUpdate(ctx context.Context, in *SendUpdateReq, opts ...grpc.CallOption) (*SendUpdateRes, error)
}

DDRPv1Client is the client API for DDRPv1 service.

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

func NewDDRPv1Client 

func NewDDRPv1Client(cc *grpc.ClientConn) DDRPv1Client

type DDRPv1Server 

type DDRPv1Server interface {
	GetStatus(context.Context, *Empty) (*GetStatusRes, error)
	AddPeer(context.Context, *AddPeerReq) (*Empty, error)
	BanPeer(context.Context, *BanPeerReq) (*Empty, error)
	UnbanPeer(context.Context, *UnbanPeerReq) (*Empty, error)
	ListPeers(*ListPeersReq, DDRPv1_ListPeersServer) error
	Checkout(context.Context, *CheckoutReq) (*CheckoutRes, error)
	WriteAt(context.Context, *WriteAtReq) (*WriteAtRes, error)
	Truncate(context.Context, *TruncateReq) (*Empty, error)
	PreCommit(context.Context, *PreCommitReq) (*PreCommitRes, error)
	Commit(context.Context, *CommitReq) (*CommitRes, error)
	ReadAt(context.Context, *ReadAtReq) (*ReadAtRes, error)
	GetBlobInfo(context.Context, *BlobInfoReq) (*BlobInfoRes, error)
	ListBlobInfo(*ListBlobInfoReq, DDRPv1_ListBlobInfoServer) error
	SendUpdate(context.Context, *SendUpdateReq) (*SendUpdateRes, error)
}

DDRPv1Server is the server API for DDRPv1 service.

type DDRPv1_ListBlobInfoClient 

type DDRPv1_ListBlobInfoClient interface {
	Recv() (*BlobInfoRes, error)
	grpc.ClientStream
}

type DDRPv1_ListBlobInfoServer 

type DDRPv1_ListBlobInfoServer interface {
	Send(*BlobInfoRes) error
	grpc.ServerStream
}

type DDRPv1_ListPeersClient 

type DDRPv1_ListPeersClient interface {
	Recv() (*ListPeersRes, error)
	grpc.ClientStream
}

type DDRPv1_ListPeersServer 

type DDRPv1_ListPeersServer interface {
	Send(*ListPeersRes) error
	grpc.ServerStream
}

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type GetNamesReq 

type GetNamesReq struct {
	Start                string   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Count                uint32   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetNamesReq) Descriptor 

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

func (*GetNamesReq) GetCount 

func (m *GetNamesReq) GetCount() uint32

func (*GetNamesReq) GetStart 

func (m *GetNamesReq) GetStart() string

func (*GetNamesReq) ProtoMessage 

func (*GetNamesReq) ProtoMessage()

func (*GetNamesReq) Reset 

func (m *GetNamesReq) Reset()

func (*GetNamesReq) String 

func (m *GetNamesReq) String() string

func (*GetNamesReq) XXX_DiscardUnknown 

func (m *GetNamesReq) XXX_DiscardUnknown()

func (*GetNamesReq) XXX_Marshal 

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

func (*GetNamesReq) XXX_Merge 

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

func (*GetNamesReq) XXX_Size 

func (m *GetNamesReq) XXX_Size() int

func (*GetNamesReq) XXX_Unmarshal 

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

type GetNamesRes 

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

func (*GetNamesRes) Descriptor 

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

func (*GetNamesRes) GetName 

func (m *GetNamesRes) GetName() string

func (*GetNamesRes) GetPublicKey 

func (m *GetNamesRes) GetPublicKey() []byte

func (*GetNamesRes) ProtoMessage 

func (*GetNamesRes) ProtoMessage()

func (*GetNamesRes) Reset 

func (m *GetNamesRes) Reset()

func (*GetNamesRes) String 

func (m *GetNamesRes) String() string

func (*GetNamesRes) XXX_DiscardUnknown 

func (m *GetNamesRes) XXX_DiscardUnknown()

func (*GetNamesRes) XXX_Marshal 

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

func (*GetNamesRes) XXX_Merge 

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

func (*GetNamesRes) XXX_Size 

func (m *GetNamesRes) XXX_Size() int

func (*GetNamesRes) XXX_Unmarshal 

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

type GetStatusRes 

type GetStatusRes struct {
	PeerID               []byte   `protobuf:"bytes,10,opt,name=peerID,proto3" json:"peerID,omitempty"`
	PeerCount            uint32   `protobuf:"varint,20,opt,name=peerCount,proto3" json:"peerCount,omitempty"`
	HeaderCount          uint32   `protobuf:"varint,30,opt,name=headerCount,proto3" json:"headerCount,omitempty"`
	TxBytes              uint64   `protobuf:"varint,40,opt,name=txBytes,proto3" json:"txBytes,omitempty"`
	RxBytes              uint64   `protobuf:"varint,50,opt,name=rxBytes,proto3" json:"rxBytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStatusRes) Descriptor 

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

func (*GetStatusRes) GetHeaderCount 

func (m *GetStatusRes) GetHeaderCount() uint32

func (*GetStatusRes) GetPeerCount 

func (m *GetStatusRes) GetPeerCount() uint32

func (*GetStatusRes) GetPeerID 

func (m *GetStatusRes) GetPeerID() []byte

func (*GetStatusRes) GetRxBytes 

func (m *GetStatusRes) GetRxBytes() uint64

func (*GetStatusRes) GetTxBytes 

func (m *GetStatusRes) GetTxBytes() uint64

func (*GetStatusRes) ProtoMessage 

func (*GetStatusRes) ProtoMessage()

func (*GetStatusRes) Reset 

func (m *GetStatusRes) Reset()

func (*GetStatusRes) String 

func (m *GetStatusRes) String() string

func (*GetStatusRes) XXX_DiscardUnknown 

func (m *GetStatusRes) XXX_DiscardUnknown()

func (*GetStatusRes) XXX_Marshal 

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

func (*GetStatusRes) XXX_Merge 

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

func (*GetStatusRes) XXX_Size 

func (m *GetStatusRes) XXX_Size() int

func (*GetStatusRes) XXX_Unmarshal 

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

type ListBlobInfoReq 

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

func (*ListBlobInfoReq) Descriptor 

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

func (*ListBlobInfoReq) GetStart 

func (m *ListBlobInfoReq) GetStart() string

func (*ListBlobInfoReq) ProtoMessage 

func (*ListBlobInfoReq) ProtoMessage()

func (*ListBlobInfoReq) Reset 

func (m *ListBlobInfoReq) Reset()

func (*ListBlobInfoReq) String 

func (m *ListBlobInfoReq) String() string

func (*ListBlobInfoReq) XXX_DiscardUnknown 

func (m *ListBlobInfoReq) XXX_DiscardUnknown()

func (*ListBlobInfoReq) XXX_Marshal 

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

func (*ListBlobInfoReq) XXX_Merge 

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

func (*ListBlobInfoReq) XXX_Size 

func (m *ListBlobInfoReq) XXX_Size() int

func (*ListBlobInfoReq) XXX_Unmarshal 

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

type ListPeersReq 

type ListPeersReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPeersReq) Descriptor 

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

func (*ListPeersReq) ProtoMessage 

func (*ListPeersReq) ProtoMessage()

func (*ListPeersReq) Reset 

func (m *ListPeersReq) Reset()

func (*ListPeersReq) String 

func (m *ListPeersReq) String() string

func (*ListPeersReq) XXX_DiscardUnknown 

func (m *ListPeersReq) XXX_DiscardUnknown()

func (*ListPeersReq) XXX_Marshal 

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

func (*ListPeersReq) XXX_Merge 

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

func (*ListPeersReq) XXX_Size 

func (m *ListPeersReq) XXX_Size() int

func (*ListPeersReq) XXX_Unmarshal 

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

type ListPeersRes 

type ListPeersRes struct {
	PeerID               []byte   `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Banned               bool     `protobuf:"varint,3,opt,name=banned,proto3" json:"banned,omitempty"`
	Connected            bool     `protobuf:"varint,4,opt,name=connected,proto3" json:"connected,omitempty"`
	TxBytes              uint64   `protobuf:"varint,5,opt,name=txBytes,proto3" json:"txBytes,omitempty"`
	RxBytes              uint64   `protobuf:"varint,6,opt,name=rxBytes,proto3" json:"rxBytes,omitempty"`
	Whitelisted          bool     `protobuf:"varint,7,opt,name=whitelisted,proto3" json:"whitelisted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPeersRes) Descriptor 

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

func (*ListPeersRes) GetBanned 

func (m *ListPeersRes) GetBanned() bool

func (*ListPeersRes) GetConnected 

func (m *ListPeersRes) GetConnected() bool

func (*ListPeersRes) GetIp 

func (m *ListPeersRes) GetIp() string

func (*ListPeersRes) GetPeerID 

func (m *ListPeersRes) GetPeerID() []byte

func (*ListPeersRes) GetRxBytes 

func (m *ListPeersRes) GetRxBytes() uint64

func (*ListPeersRes) GetTxBytes 

func (m *ListPeersRes) GetTxBytes() uint64

func (*ListPeersRes) GetWhitelisted 

func (m *ListPeersRes) GetWhitelisted() bool

func (*ListPeersRes) ProtoMessage 

func (*ListPeersRes) ProtoMessage()

func (*ListPeersRes) Reset 

func (m *ListPeersRes) Reset()

func (*ListPeersRes) String 

func (m *ListPeersRes) String() string

func (*ListPeersRes) XXX_DiscardUnknown 

func (m *ListPeersRes) XXX_DiscardUnknown()

func (*ListPeersRes) XXX_Marshal 

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

func (*ListPeersRes) XXX_Merge 

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

func (*ListPeersRes) XXX_Size 

func (m *ListPeersRes) XXX_Size() int

func (*ListPeersRes) XXX_Unmarshal 

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

type PreCommitReq 

type PreCommitReq struct {
	TxID                 uint32   `protobuf:"varint,1,opt,name=txID,proto3" json:"txID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PreCommitReq) Descriptor 

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

func (*PreCommitReq) GetTxID 

func (m *PreCommitReq) GetTxID() uint32

func (*PreCommitReq) ProtoMessage 

func (*PreCommitReq) ProtoMessage()

func (*PreCommitReq) Reset 

func (m *PreCommitReq) Reset()

func (*PreCommitReq) String 

func (m *PreCommitReq) String() string

func (*PreCommitReq) XXX_DiscardUnknown 

func (m *PreCommitReq) XXX_DiscardUnknown()

func (*PreCommitReq) XXX_Marshal 

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

func (*PreCommitReq) XXX_Merge 

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

func (*PreCommitReq) XXX_Size 

func (m *PreCommitReq) XXX_Size() int

func (*PreCommitReq) XXX_Unmarshal 

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

type PreCommitRes 

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

func (*PreCommitRes) Descriptor 

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

func (*PreCommitRes) GetMerkleRoot 

func (m *PreCommitRes) GetMerkleRoot() []byte

func (*PreCommitRes) ProtoMessage 

func (*PreCommitRes) ProtoMessage()

func (*PreCommitRes) Reset 

func (m *PreCommitRes) Reset()

func (*PreCommitRes) String 

func (m *PreCommitRes) String() string

func (*PreCommitRes) XXX_DiscardUnknown 

func (m *PreCommitRes) XXX_DiscardUnknown()

func (*PreCommitRes) XXX_Marshal 

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

func (*PreCommitRes) XXX_Merge 

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

func (*PreCommitRes) XXX_Size 

func (m *PreCommitRes) XXX_Size() int

func (*PreCommitRes) XXX_Unmarshal 

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

type ReadAtReq 

type ReadAtReq struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Offset               uint32   `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Len                  uint32   `protobuf:"varint,3,opt,name=len,proto3" json:"len,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadAtReq) Descriptor 

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

func (*ReadAtReq) GetLen 

func (m *ReadAtReq) GetLen() uint32

func (*ReadAtReq) GetName 

func (m *ReadAtReq) GetName() string

func (*ReadAtReq) GetOffset 

func (m *ReadAtReq) GetOffset() uint32

func (*ReadAtReq) ProtoMessage 

func (*ReadAtReq) ProtoMessage()

func (*ReadAtReq) Reset 

func (m *ReadAtReq) Reset()

func (*ReadAtReq) String 

func (m *ReadAtReq) String() string

func (*ReadAtReq) XXX_DiscardUnknown 

func (m *ReadAtReq) XXX_DiscardUnknown()

func (*ReadAtReq) XXX_Marshal 

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

func (*ReadAtReq) XXX_Merge 

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

func (*ReadAtReq) XXX_Size 

func (m *ReadAtReq) XXX_Size() int

func (*ReadAtReq) XXX_Unmarshal 

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

type ReadAtRes 

type ReadAtRes struct {
	Offset               uint32   `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadAtRes) Descriptor 

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

func (*ReadAtRes) GetData 

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

func (*ReadAtRes) GetOffset 

func (m *ReadAtRes) GetOffset() uint32

func (*ReadAtRes) ProtoMessage 

func (*ReadAtRes) ProtoMessage()

func (*ReadAtRes) Reset 

func (m *ReadAtRes) Reset()

func (*ReadAtRes) String 

func (m *ReadAtRes) String() string

func (*ReadAtRes) XXX_DiscardUnknown 

func (m *ReadAtRes) XXX_DiscardUnknown()

func (*ReadAtRes) XXX_Marshal 

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

func (*ReadAtRes) XXX_Merge 

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

func (*ReadAtRes) XXX_Size 

func (m *ReadAtRes) XXX_Size() int

func (*ReadAtRes) XXX_Unmarshal 

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

type SendUpdateReq 

type SendUpdateReq 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 (*SendUpdateReq) Descriptor 

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

func (*SendUpdateReq) GetName 

func (m *SendUpdateReq) GetName() string

func (*SendUpdateReq) ProtoMessage 

func (*SendUpdateReq) ProtoMessage()

func (*SendUpdateReq) Reset 

func (m *SendUpdateReq) Reset()

func (*SendUpdateReq) String 

func (m *SendUpdateReq) String() string

func (*SendUpdateReq) XXX_DiscardUnknown 

func (m *SendUpdateReq) XXX_DiscardUnknown()

func (*SendUpdateReq) XXX_Marshal 

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

func (*SendUpdateReq) XXX_Merge 

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

func (*SendUpdateReq) XXX_Size 

func (m *SendUpdateReq) XXX_Size() int

func (*SendUpdateReq) XXX_Unmarshal 

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

type SendUpdateRes 

type SendUpdateRes struct {
	RecipientCount       uint32   `protobuf:"varint,1,opt,name=recipientCount,proto3" json:"recipientCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendUpdateRes) Descriptor 

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

func (*SendUpdateRes) GetRecipientCount 

func (m *SendUpdateRes) GetRecipientCount() uint32

func (*SendUpdateRes) ProtoMessage 

func (*SendUpdateRes) ProtoMessage()

func (*SendUpdateRes) Reset 

func (m *SendUpdateRes) Reset()

func (*SendUpdateRes) String 

func (m *SendUpdateRes) String() string

func (*SendUpdateRes) XXX_DiscardUnknown 

func (m *SendUpdateRes) XXX_DiscardUnknown()

func (*SendUpdateRes) XXX_Marshal 

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

func (*SendUpdateRes) XXX_Merge 

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

func (*SendUpdateRes) XXX_Size 

func (m *SendUpdateRes) XXX_Size() int

func (*SendUpdateRes) XXX_Unmarshal 

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

type TruncateReq 

type TruncateReq struct {
	TxID                 uint32   `protobuf:"varint,1,opt,name=txID,proto3" json:"txID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TruncateReq) Descriptor 

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

func (*TruncateReq) GetTxID 

func (m *TruncateReq) GetTxID() uint32

func (*TruncateReq) ProtoMessage 

func (*TruncateReq) ProtoMessage()

func (*TruncateReq) Reset 

func (m *TruncateReq) Reset()

func (*TruncateReq) String 

func (m *TruncateReq) String() string

func (*TruncateReq) XXX_DiscardUnknown 

func (m *TruncateReq) XXX_DiscardUnknown()

func (*TruncateReq) XXX_Marshal 

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

func (*TruncateReq) XXX_Merge 

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

func (*TruncateReq) XXX_Size 

func (m *TruncateReq) XXX_Size() int

func (*TruncateReq) XXX_Unmarshal 

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

type TruncateRes 

type TruncateRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TruncateRes) Descriptor 

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

func (*TruncateRes) ProtoMessage 

func (*TruncateRes) ProtoMessage()

func (*TruncateRes) Reset 

func (m *TruncateRes) Reset()

func (*TruncateRes) String 

func (m *TruncateRes) String() string

func (*TruncateRes) XXX_DiscardUnknown 

func (m *TruncateRes) XXX_DiscardUnknown()

func (*TruncateRes) XXX_Marshal 

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

func (*TruncateRes) XXX_Merge 

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

func (*TruncateRes) XXX_Size 

func (m *TruncateRes) XXX_Size() int

func (*TruncateRes) XXX_Unmarshal 

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

type UnbanPeerReq 

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

func (*UnbanPeerReq) Descriptor 

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

func (*UnbanPeerReq) GetIp 

func (m *UnbanPeerReq) GetIp() string

func (*UnbanPeerReq) ProtoMessage 

func (*UnbanPeerReq) ProtoMessage()

func (*UnbanPeerReq) Reset 

func (m *UnbanPeerReq) Reset()

func (*UnbanPeerReq) String 

func (m *UnbanPeerReq) String() string

func (*UnbanPeerReq) XXX_DiscardUnknown 

func (m *UnbanPeerReq) XXX_DiscardUnknown()

func (*UnbanPeerReq) XXX_Marshal 

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

func (*UnbanPeerReq) XXX_Merge 

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

func (*UnbanPeerReq) XXX_Size 

func (m *UnbanPeerReq) XXX_Size() int

func (*UnbanPeerReq) XXX_Unmarshal 

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

type WriteAtReq 

type WriteAtReq struct {
	TxID                 uint32   `protobuf:"varint,1,opt,name=txID,proto3" json:"txID,omitempty"`
	Offset               uint32   `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteAtReq) Descriptor 

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

func (*WriteAtReq) GetData 

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

func (*WriteAtReq) GetOffset 

func (m *WriteAtReq) GetOffset() uint32

func (*WriteAtReq) GetTxID 

func (m *WriteAtReq) GetTxID() uint32

func (*WriteAtReq) ProtoMessage 

func (*WriteAtReq) ProtoMessage()

func (*WriteAtReq) Reset 

func (m *WriteAtReq) Reset()

func (*WriteAtReq) String 

func (m *WriteAtReq) String() string

func (*WriteAtReq) XXX_DiscardUnknown 

func (m *WriteAtReq) XXX_DiscardUnknown()

func (*WriteAtReq) XXX_Marshal 

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

func (*WriteAtReq) XXX_Merge 

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

func (*WriteAtReq) XXX_Size 

func (m *WriteAtReq) XXX_Size() int

func (*WriteAtReq) XXX_Unmarshal 

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

type WriteAtRes 

type WriteAtRes struct {
	BytesWritten         uint32   `protobuf:"varint,1,opt,name=bytesWritten,proto3" json:"bytesWritten,omitempty"`
	WriteErr             string   `protobuf:"bytes,2,opt,name=writeErr,proto3" json:"writeErr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteAtRes) Descriptor 

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

func (*WriteAtRes) GetBytesWritten 

func (m *WriteAtRes) GetBytesWritten() uint32

func (*WriteAtRes) GetWriteErr 

func (m *WriteAtRes) GetWriteErr() string

func (*WriteAtRes) ProtoMessage 

func (*WriteAtRes) ProtoMessage()

func (*WriteAtRes) Reset 

func (m *WriteAtRes) Reset()

func (*WriteAtRes) String 

func (m *WriteAtRes) String() string

func (*WriteAtRes) XXX_DiscardUnknown 

func (m *WriteAtRes) XXX_DiscardUnknown()

func (*WriteAtRes) XXX_Marshal 

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

func (*WriteAtRes) XXX_Merge 

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

func (*WriteAtRes) XXX_Size 

func (m *WriteAtRes) XXX_Size() int

func (*WriteAtRes) XXX_Unmarshal 

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