pb

package

Go to main page

Versions in this module

v1

v1.1.1

Dec 11, 2019

Changes in this version

type EXTRASTYPE

+ const EXTRASTYPE_MDNS

v1.1.1-rc1

Dec 1, 2019

v1.1.0

Nov 29, 2019

Changes in this version

+ var ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupDag = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupFile = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupKeystore = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupNamesys = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupNode = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupPubsub = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupStatus = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupUtil = fmt.Errorf("proto: unexpected end of group")

+ var P2PREQTYPE_name = map[int32]string

+ var P2PREQTYPE_value = map[string]int32

type NodeAPIClient

+ P2P func(ctx context.Context, in *P2PRequest, opts ...grpc.CallOption) (*P2PResponse, error)

type NodeAPIServer

+ P2P func(context.Context, *P2PRequest) (*P2PResponse, error)

+ type P2PLsInfo struct

+ ListenAddress string

+ Local bool

+ ProtocolName string

+ TargetAddress string

+ func NewPopulatedP2PLsInfo(r randyNode, easy bool) *P2PLsInfo

+ func (*P2PLsInfo) Descriptor() ([]byte, []int)

+ func (*P2PLsInfo) ProtoMessage()

+ func (m *P2PLsInfo) GetListenAddress() string

+ func (m *P2PLsInfo) GetLocal() bool

+ func (m *P2PLsInfo) GetProtocolName() string

+ func (m *P2PLsInfo) GetTargetAddress() string

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

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

+ func (m *P2PLsInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *P2PLsInfo) Reset()

+ func (m *P2PLsInfo) Size() (n int)

+ func (m *P2PLsInfo) Unmarshal(dAtA []byte) error

+ func (m *P2PLsInfo) XXX_DiscardUnknown()

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

+ func (m *P2PLsInfo) XXX_Merge(src proto.Message)

+ func (m *P2PLsInfo) XXX_Size() int

+ func (m *P2PLsInfo) XXX_Unmarshal(b []byte) error

+ func (this *P2PLsInfo) Equal(that interface{}) bool

+ func (this *P2PLsInfo) GoString() string

+ func (this *P2PLsInfo) String() string

+ func (this *P2PLsInfo) VerboseEqual(that interface{}) error

+ type P2PREQTYPE int32

+ const P2PREQTYPE_CLOSE

+ const P2PREQTYPE_FORWARD

+ const P2PREQTYPE_LISTEN

+ const P2PREQTYPE_LS

+ func (P2PREQTYPE) EnumDescriptor() ([]byte, []int)

+ func (x P2PREQTYPE) String() string

+ type P2PRequest struct

+ All bool

+ AllowCustomProtocols bool

+ ListenAddress string

+ ProtocolName string

+ RemoteAddress string

+ ReportPeerID bool

+ RequestType P2PREQTYPE

+ TargetAddress string

+ Verbose bool

+ func NewPopulatedP2PRequest(r randyNode, easy bool) *P2PRequest

+ func (*P2PRequest) Descriptor() ([]byte, []int)

+ func (*P2PRequest) ProtoMessage()

+ func (m *P2PRequest) GetAll() bool

+ func (m *P2PRequest) GetAllowCustomProtocols() bool

+ func (m *P2PRequest) GetListenAddress() string

+ func (m *P2PRequest) GetProtocolName() string

+ func (m *P2PRequest) GetRemoteAddress() string

+ func (m *P2PRequest) GetReportPeerID() bool

+ func (m *P2PRequest) GetRequestType() P2PREQTYPE

+ func (m *P2PRequest) GetTargetAddress() string

+ func (m *P2PRequest) GetVerbose() bool

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

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

+ func (m *P2PRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *P2PRequest) Reset()

+ func (m *P2PRequest) Size() (n int)

+ func (m *P2PRequest) Unmarshal(dAtA []byte) error

+ func (m *P2PRequest) XXX_DiscardUnknown()

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

+ func (m *P2PRequest) XXX_Merge(src proto.Message)

+ func (m *P2PRequest) XXX_Size() int

+ func (m *P2PRequest) XXX_Unmarshal(b []byte) error

+ func (this *P2PRequest) Equal(that interface{}) bool

+ func (this *P2PRequest) GoString() string

+ func (this *P2PRequest) String() string

+ func (this *P2PRequest) VerboseEqual(that interface{}) error

+ type P2PResponse struct

+ ConnsClosed int32

+ Names []string

+ RequestType P2PREQTYPE

+ StreamInfos []*P2PLsInfo

+ func NewPopulatedP2PResponse(r randyNode, easy bool) *P2PResponse

+ func (*P2PResponse) Descriptor() ([]byte, []int)

+ func (*P2PResponse) ProtoMessage()

+ func (m *P2PResponse) GetConnsClosed() int32

+ func (m *P2PResponse) GetNames() []string

+ func (m *P2PResponse) GetRequestType() P2PREQTYPE

+ func (m *P2PResponse) GetStreamInfos() []*P2PLsInfo

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

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

+ func (m *P2PResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *P2PResponse) Reset()

+ func (m *P2PResponse) Size() (n int)

+ func (m *P2PResponse) Unmarshal(dAtA []byte) error

+ func (m *P2PResponse) XXX_DiscardUnknown()

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

+ func (m *P2PResponse) XXX_Merge(src proto.Message)

+ func (m *P2PResponse) XXX_Size() int

+ func (m *P2PResponse) XXX_Unmarshal(b []byte) error

+ func (this *P2PResponse) Equal(that interface{}) bool

+ func (this *P2PResponse) GoString() string

+ func (this *P2PResponse) String() string

+ func (this *P2PResponse) VerboseEqual(that interface{}) error

type UnimplementedNodeAPIServer

+ func (*UnimplementedNodeAPIServer) P2P(ctx context.Context, req *P2PRequest) (*P2PResponse, error)

v1.0.1

Nov 10, 2019

v1.0.0

Oct 22, 2019

Changes in this version

+ var APISTATUS_name = map[int32]string

+ var APISTATUS_value = map[string]int32

+ var BSREQOPTS_name = map[int32]string

+ var BSREQOPTS_value = map[string]int32

+ var BSREQTYPE_name = map[int32]string

+ var BSREQTYPE_value = map[string]int32

+ var EXTRASTYPE_name = map[int32]string

+ var EXTRASTYPE_value = map[string]int32

+ var ErrIntOverflowAdmin = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowDag = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowFile = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowKeystore = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowNamesys = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowNode = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowPubsub = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowStatus = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowUtil = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthDag = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthFile = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthKeystore = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthNamesys = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthPubsub = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthStatus = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthUtil = fmt.Errorf("proto: negative length found during unmarshaling")

+ var GCREQTYPE_name = map[int32]string

+ var GCREQTYPE_value = map[string]int32

+ var REFREQOPTS_name = map[int32]string

+ var REFREQOPTS_value = map[string]int32

+ var REFREQTYPE_name = map[int32]string

+ var REFREQTYPE_value = map[string]int32

+ func RegisterAdminAPIServer(s *grpc.Server, srv AdminAPIServer)

+ func RegisterDagAPIServer(s *grpc.Server, srv DagAPIServer)

+ func RegisterFileAPIServer(s *grpc.Server, srv FileAPIServer)

+ func RegisterKeystoreAPIServer(s *grpc.Server, srv KeystoreAPIServer)

+ func RegisterNameSysAPIServer(s *grpc.Server, srv NameSysAPIServer)

+ func RegisterNodeAPIServer(s *grpc.Server, srv NodeAPIServer)

+ func RegisterPubSubAPIServer(s *grpc.Server, srv PubSubAPIServer)

+ func RegisterStatusAPIServer(s *grpc.Server, srv StatusAPIServer)

+ type APISTATUS int32

+ const APISTATUS_DEGRADED_PERFORMANCE

+ const APISTATUS_ERROR

+ const APISTATUS_ONLINE

+ const APISTATUS_PURGING

+ func (APISTATUS) EnumDescriptor() ([]byte, []int)

+ func (x APISTATUS) String() string

+ type AddLinksRequest struct

+ Hash string

+ HashFunc string

+ Links map[string]string

+ func NewPopulatedAddLinksRequest(r randyDag, easy bool) *AddLinksRequest

+ func (*AddLinksRequest) Descriptor() ([]byte, []int)

+ func (*AddLinksRequest) ProtoMessage()

+ func (m *AddLinksRequest) GetHash() string

+ func (m *AddLinksRequest) GetHashFunc() string

+ func (m *AddLinksRequest) GetLinks() map[string]string

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

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

+ func (m *AddLinksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AddLinksRequest) Reset()

+ func (m *AddLinksRequest) Size() (n int)

+ func (m *AddLinksRequest) Unmarshal(dAtA []byte) error

+ func (m *AddLinksRequest) XXX_DiscardUnknown()

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

+ func (m *AddLinksRequest) XXX_Merge(src proto.Message)

+ func (m *AddLinksRequest) XXX_Size() int

+ func (m *AddLinksRequest) XXX_Unmarshal(b []byte) error

+ func (this *AddLinksRequest) Equal(that interface{}) bool

+ func (this *AddLinksRequest) GoString() string

+ func (this *AddLinksRequest) String() string

+ func (this *AddLinksRequest) VerboseEqual(that interface{}) error

+ type AdminAPIClient interface

+ Blockstore func(ctx context.Context, in *BlockstoreRequest, opts ...grpc.CallOption) (*BlockstoreResponse, error)

+ ManageGC func(ctx context.Context, in *ManageGCRequest, opts ...grpc.CallOption) (*ManageGCResponse, error)

+ RefCount func(ctx context.Context, in *RefCountRequest, opts ...grpc.CallOption) (*RefCountResponse, error)

+ func NewAdminAPIClient(cc *grpc.ClientConn) AdminAPIClient

+ type AdminAPIServer interface

+ Blockstore func(context.Context, *BlockstoreRequest) (*BlockstoreResponse, error)

+ ManageGC func(context.Context, *ManageGCRequest) (*ManageGCResponse, error)

+ RefCount func(context.Context, *RefCountRequest) (*RefCountResponse, error)

+ type BSREQOPTS int32

+ const BSREQOPTS_BS_FORCE

+ const BSREQOPTS_DEFAULT

+ func (BSREQOPTS) EnumDescriptor() ([]byte, []int)

+ func (x BSREQOPTS) String() string

+ type BSREQTYPE int32

+ const BSREQTYPE_BS_DELETE

+ const BSREQTYPE_BS_GET

+ const BSREQTYPE_BS_GET_MANY

+ const BSREQTYPE_BS_PUT

+ const BSREQTYPE_BS_PUT_MANY

+ func (BSREQTYPE) EnumDescriptor() ([]byte, []int)

+ func (x BSREQTYPE) String() string

+ type Blob struct

+ Content []byte

+ func NewPopulatedBlob(r randyFile, easy bool) *Blob

+ func (*Blob) Descriptor() ([]byte, []int)

+ func (*Blob) ProtoMessage()

+ func (m *Blob) GetContent() []byte

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

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

+ func (m *Blob) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Blob) Reset()

+ func (m *Blob) Size() (n int)

+ func (m *Blob) Unmarshal(dAtA []byte) error

+ func (m *Blob) XXX_DiscardUnknown()

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

+ func (m *Blob) XXX_Merge(src proto.Message)

+ func (m *Blob) XXX_Size() int

+ func (m *Blob) XXX_Unmarshal(b []byte) error

+ func (this *Blob) Equal(that interface{}) bool

+ func (this *Blob) GoString() string

+ func (this *Blob) String() string

+ func (this *Blob) VerboseEqual(that interface{}) error

+ type Block struct

+ Cid string

+ Data []byte

+ func NewPopulatedBlock(r randyAdmin, easy bool) *Block

+ func (*Block) Descriptor() ([]byte, []int)

+ func (*Block) ProtoMessage()

+ func (m *Block) GetCid() string

+ func (m *Block) GetData() []byte

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

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

+ func (m *Block) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Block) Reset()

+ func (m *Block) Size() (n int)

+ func (m *Block) Unmarshal(dAtA []byte) error

+ func (m *Block) XXX_DiscardUnknown()

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

+ func (m *Block) XXX_Merge(src proto.Message)

+ func (m *Block) XXX_Size() int

+ func (m *Block) XXX_Unmarshal(b []byte) error

+ func (this *Block) Equal(that interface{}) bool

+ func (this *Block) GoString() string

+ func (this *Block) String() string

+ func (this *Block) VerboseEqual(that interface{}) error

+ type BlockstoreRequest struct

+ Cids []string

+ ReqOpts BSREQOPTS

+ ReqType BSREQTYPE

+ func NewPopulatedBlockstoreRequest(r randyAdmin, easy bool) *BlockstoreRequest

+ func (*BlockstoreRequest) Descriptor() ([]byte, []int)

+ func (*BlockstoreRequest) ProtoMessage()

+ func (m *BlockstoreRequest) GetCids() []string

+ func (m *BlockstoreRequest) GetReqOpts() BSREQOPTS

+ func (m *BlockstoreRequest) GetReqType() BSREQTYPE

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

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

+ func (m *BlockstoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BlockstoreRequest) Reset()

+ func (m *BlockstoreRequest) Size() (n int)

+ func (m *BlockstoreRequest) Unmarshal(dAtA []byte) error

+ func (m *BlockstoreRequest) XXX_DiscardUnknown()

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

+ func (m *BlockstoreRequest) XXX_Merge(src proto.Message)

+ func (m *BlockstoreRequest) XXX_Size() int

+ func (m *BlockstoreRequest) XXX_Unmarshal(b []byte) error

+ func (this *BlockstoreRequest) Equal(that interface{}) bool

+ func (this *BlockstoreRequest) GoString() string

+ func (this *BlockstoreRequest) String() string

+ func (this *BlockstoreRequest) VerboseEqual(that interface{}) error

+ type BlockstoreResponse struct

+ Blocks []*Block

+ func NewPopulatedBlockstoreResponse(r randyAdmin, easy bool) *BlockstoreResponse

+ func (*BlockstoreResponse) Descriptor() ([]byte, []int)

+ func (*BlockstoreResponse) ProtoMessage()

+ func (m *BlockstoreResponse) GetBlocks() []*Block

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

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

+ func (m *BlockstoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BlockstoreResponse) Reset()

+ func (m *BlockstoreResponse) Size() (n int)

+ func (m *BlockstoreResponse) Unmarshal(dAtA []byte) error

+ func (m *BlockstoreResponse) XXX_DiscardUnknown()

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

+ func (m *BlockstoreResponse) XXX_Merge(src proto.Message)

+ func (m *BlockstoreResponse) XXX_Size() int

+ func (m *BlockstoreResponse) XXX_Unmarshal(b []byte) error

+ func (this *BlockstoreResponse) Equal(that interface{}) bool

+ func (this *BlockstoreResponse) GoString() string

+ func (this *BlockstoreResponse) String() string

+ func (this *BlockstoreResponse) VerboseEqual(that interface{}) error

+ type ConnectRequest struct

+ MultiAddrs []string

+ func NewPopulatedConnectRequest(r randyNode, easy bool) *ConnectRequest

+ func (*ConnectRequest) Descriptor() ([]byte, []int)

+ func (*ConnectRequest) ProtoMessage()

+ func (m *ConnectRequest) GetMultiAddrs() []string

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

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

+ func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConnectRequest) Reset()

+ func (m *ConnectRequest) Size() (n int)

+ func (m *ConnectRequest) Unmarshal(dAtA []byte) error

+ func (m *ConnectRequest) XXX_DiscardUnknown()

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

+ func (m *ConnectRequest) XXX_Merge(src proto.Message)

+ func (m *ConnectRequest) XXX_Size() int

+ func (m *ConnectRequest) XXX_Unmarshal(b []byte) error

+ func (this *ConnectRequest) Equal(that interface{}) bool

+ func (this *ConnectRequest) GoString() string

+ func (this *ConnectRequest) String() string

+ func (this *ConnectRequest) VerboseEqual(that interface{}) error

+ type DagAPIClient interface

+ AddLinksToNode func(ctx context.Context, in *AddLinksRequest, opts ...grpc.CallOption) (*DagPutResponse, error)

+ DagGet func(ctx context.Context, in *DagGetRequest, opts ...grpc.CallOption) (*DagGetResponse, error)

+ DagPut func(ctx context.Context, in *DagPutRequest, opts ...grpc.CallOption) (*DagPutResponse, error)

+ GetLinks func(ctx context.Context, in *GetLinksRequest, opts ...grpc.CallOption) (*GetLinksResponse, error)

+ NewIPLDNode func(ctx context.Context, in *NewIPLDNodeRequest, opts ...grpc.CallOption) (*DagPutResponse, error)

+ func NewDagAPIClient(cc *grpc.ClientConn) DagAPIClient

+ type DagAPIServer interface

+ AddLinksToNode func(context.Context, *AddLinksRequest) (*DagPutResponse, error)

+ DagGet func(context.Context, *DagGetRequest) (*DagGetResponse, error)

+ DagPut func(context.Context, *DagPutRequest) (*DagPutResponse, error)

+ GetLinks func(context.Context, *GetLinksRequest) (*GetLinksResponse, error)

+ NewIPLDNode func(context.Context, *NewIPLDNodeRequest) (*DagPutResponse, error)

+ type DagGetRequest struct

+ Hash string

+ func NewPopulatedDagGetRequest(r randyDag, easy bool) *DagGetRequest

+ func (*DagGetRequest) Descriptor() ([]byte, []int)

+ func (*DagGetRequest) ProtoMessage()

+ func (m *DagGetRequest) GetHash() string

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

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

+ func (m *DagGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DagGetRequest) Reset()

+ func (m *DagGetRequest) Size() (n int)

+ func (m *DagGetRequest) Unmarshal(dAtA []byte) error

+ func (m *DagGetRequest) XXX_DiscardUnknown()

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

+ func (m *DagGetRequest) XXX_Merge(src proto.Message)

+ func (m *DagGetRequest) XXX_Size() int

+ func (m *DagGetRequest) XXX_Unmarshal(b []byte) error

+ func (this *DagGetRequest) Equal(that interface{}) bool

+ func (this *DagGetRequest) GoString() string

+ func (this *DagGetRequest) String() string

+ func (this *DagGetRequest) VerboseEqual(that interface{}) error

+ type DagGetResponse struct

+ RawData []byte

+ func NewPopulatedDagGetResponse(r randyDag, easy bool) *DagGetResponse

+ func (*DagGetResponse) Descriptor() ([]byte, []int)

+ func (*DagGetResponse) ProtoMessage()

+ func (m *DagGetResponse) GetRawData() []byte

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

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

+ func (m *DagGetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DagGetResponse) Reset()

+ func (m *DagGetResponse) Size() (n int)

+ func (m *DagGetResponse) Unmarshal(dAtA []byte) error

+ func (m *DagGetResponse) XXX_DiscardUnknown()

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

+ func (m *DagGetResponse) XXX_Merge(src proto.Message)

+ func (m *DagGetResponse) XXX_Size() int

+ func (m *DagGetResponse) XXX_Unmarshal(b []byte) error

+ func (this *DagGetResponse) Equal(that interface{}) bool

+ func (this *DagGetResponse) GoString() string

+ func (this *DagGetResponse) String() string

+ func (this *DagGetResponse) VerboseEqual(that interface{}) error

+ type DagPutRequest struct

+ CidVersion int64

+ Data []byte

+ HashFunc string

+ ObjectEncoding string

+ SerializationFormat string

+ func NewPopulatedDagPutRequest(r randyDag, easy bool) *DagPutRequest

+ func (*DagPutRequest) Descriptor() ([]byte, []int)

+ func (*DagPutRequest) ProtoMessage()

+ func (m *DagPutRequest) GetCidVersion() int64

+ func (m *DagPutRequest) GetData() []byte

+ func (m *DagPutRequest) GetHashFunc() string

+ func (m *DagPutRequest) GetObjectEncoding() string

+ func (m *DagPutRequest) GetSerializationFormat() string

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

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

+ func (m *DagPutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DagPutRequest) Reset()

+ func (m *DagPutRequest) Size() (n int)

+ func (m *DagPutRequest) Unmarshal(dAtA []byte) error

+ func (m *DagPutRequest) XXX_DiscardUnknown()

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

+ func (m *DagPutRequest) XXX_Merge(src proto.Message)

+ func (m *DagPutRequest) XXX_Size() int

+ func (m *DagPutRequest) XXX_Unmarshal(b []byte) error

+ func (this *DagPutRequest) Equal(that interface{}) bool

+ func (this *DagPutRequest) GoString() string

+ func (this *DagPutRequest) String() string

+ func (this *DagPutRequest) VerboseEqual(that interface{}) error

+ type DagPutResponse struct

+ Hashes []string

+ func NewPopulatedDagPutResponse(r randyDag, easy bool) *DagPutResponse

+ func (*DagPutResponse) Descriptor() ([]byte, []int)

+ func (*DagPutResponse) ProtoMessage()

+ func (m *DagPutResponse) GetHashes() []string

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

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

+ func (m *DagPutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DagPutResponse) Reset()

+ func (m *DagPutResponse) Size() (n int)

+ func (m *DagPutResponse) Unmarshal(dAtA []byte) error

+ func (m *DagPutResponse) XXX_DiscardUnknown()

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

+ func (m *DagPutResponse) XXX_Merge(src proto.Message)

+ func (m *DagPutResponse) XXX_Size() int

+ func (m *DagPutResponse) XXX_Unmarshal(b []byte) error

+ func (this *DagPutResponse) Equal(that interface{}) bool

+ func (this *DagPutResponse) GoString() string

+ func (this *DagPutResponse) String() string

+ func (this *DagPutResponse) VerboseEqual(that interface{}) error

+ type DisableExtrasRequest struct

+ ExtrasFeature EXTRASTYPE

+ func NewPopulatedDisableExtrasRequest(r randyNode, easy bool) *DisableExtrasRequest

+ func (*DisableExtrasRequest) Descriptor() ([]byte, []int)

+ func (*DisableExtrasRequest) ProtoMessage()

+ func (m *DisableExtrasRequest) GetExtrasFeature() EXTRASTYPE

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

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

+ func (m *DisableExtrasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DisableExtrasRequest) Reset()

+ func (m *DisableExtrasRequest) Size() (n int)

+ func (m *DisableExtrasRequest) Unmarshal(dAtA []byte) error

+ func (m *DisableExtrasRequest) XXX_DiscardUnknown()

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

+ func (m *DisableExtrasRequest) XXX_Merge(src proto.Message)

+ func (m *DisableExtrasRequest) XXX_Size() int

+ func (m *DisableExtrasRequest) XXX_Unmarshal(b []byte) error

+ func (this *DisableExtrasRequest) Equal(that interface{}) bool

+ func (this *DisableExtrasRequest) GoString() string

+ func (this *DisableExtrasRequest) String() string

+ func (this *DisableExtrasRequest) VerboseEqual(that interface{}) error

+ type DisconnectRequest struct

+ PeerIDs []string

+ func NewPopulatedDisconnectRequest(r randyNode, easy bool) *DisconnectRequest

+ func (*DisconnectRequest) Descriptor() ([]byte, []int)

+ func (*DisconnectRequest) ProtoMessage()

+ func (m *DisconnectRequest) GetPeerIDs() []string

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

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

+ func (m *DisconnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DisconnectRequest) Reset()

+ func (m *DisconnectRequest) Size() (n int)

+ func (m *DisconnectRequest) Unmarshal(dAtA []byte) error

+ func (m *DisconnectRequest) XXX_DiscardUnknown()

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

+ func (m *DisconnectRequest) XXX_Merge(src proto.Message)

+ func (m *DisconnectRequest) XXX_Size() int

+ func (m *DisconnectRequest) XXX_Unmarshal(b []byte) error

+ func (this *DisconnectRequest) Equal(that interface{}) bool

+ func (this *DisconnectRequest) GoString() string

+ func (this *DisconnectRequest) String() string

+ func (this *DisconnectRequest) VerboseEqual(that interface{}) error

+ type DisconnectResponse struct

+ Status map[string]*DisconnectResponse_StatusMessage

+ func NewPopulatedDisconnectResponse(r randyNode, easy bool) *DisconnectResponse

+ func (*DisconnectResponse) Descriptor() ([]byte, []int)

+ func (*DisconnectResponse) ProtoMessage()

+ func (m *DisconnectResponse) GetStatus() map[string]*DisconnectResponse_StatusMessage

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

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

+ func (m *DisconnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DisconnectResponse) Reset()

+ func (m *DisconnectResponse) Size() (n int)

+ func (m *DisconnectResponse) Unmarshal(dAtA []byte) error

+ func (m *DisconnectResponse) XXX_DiscardUnknown()

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

+ func (m *DisconnectResponse) XXX_Merge(src proto.Message)

+ func (m *DisconnectResponse) XXX_Size() int

+ func (m *DisconnectResponse) XXX_Unmarshal(b []byte) error

+ func (this *DisconnectResponse) Equal(that interface{}) bool

+ func (this *DisconnectResponse) GoString() string

+ func (this *DisconnectResponse) String() string

+ func (this *DisconnectResponse) VerboseEqual(that interface{}) error

+ type DisconnectResponse_StatusMessage struct

+ Disconnected bool

+ Reason string

+ func NewPopulatedDisconnectResponse_StatusMessage(r randyNode, easy bool) *DisconnectResponse_StatusMessage

+ func (*DisconnectResponse_StatusMessage) Descriptor() ([]byte, []int)

+ func (*DisconnectResponse_StatusMessage) ProtoMessage()

+ func (m *DisconnectResponse_StatusMessage) GetDisconnected() bool

+ func (m *DisconnectResponse_StatusMessage) GetReason() string

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

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

+ func (m *DisconnectResponse_StatusMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DisconnectResponse_StatusMessage) Reset()

+ func (m *DisconnectResponse_StatusMessage) Size() (n int)

+ func (m *DisconnectResponse_StatusMessage) Unmarshal(dAtA []byte) error

+ func (m *DisconnectResponse_StatusMessage) XXX_DiscardUnknown()

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

+ func (m *DisconnectResponse_StatusMessage) XXX_Merge(src proto.Message)

+ func (m *DisconnectResponse_StatusMessage) XXX_Size() int

+ func (m *DisconnectResponse_StatusMessage) XXX_Unmarshal(b []byte) error

+ func (this *DisconnectResponse_StatusMessage) Equal(that interface{}) bool

+ func (this *DisconnectResponse_StatusMessage) GoString() string

+ func (this *DisconnectResponse_StatusMessage) String() string

+ func (this *DisconnectResponse_StatusMessage) VerboseEqual(that interface{}) error

+ type DownloadRequest struct

+ ChunkSize int32

+ Hash string

+ func NewPopulatedDownloadRequest(r randyFile, easy bool) *DownloadRequest

+ func (*DownloadRequest) Descriptor() ([]byte, []int)

+ func (*DownloadRequest) ProtoMessage()

+ func (m *DownloadRequest) GetChunkSize() int32

+ func (m *DownloadRequest) GetHash() string

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

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

+ func (m *DownloadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DownloadRequest) Reset()

+ func (m *DownloadRequest) Size() (n int)

+ func (m *DownloadRequest) Unmarshal(dAtA []byte) error

+ func (m *DownloadRequest) XXX_DiscardUnknown()

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

+ func (m *DownloadRequest) XXX_Merge(src proto.Message)

+ func (m *DownloadRequest) XXX_Size() int

+ func (m *DownloadRequest) XXX_Unmarshal(b []byte) error

+ func (this *DownloadRequest) Equal(that interface{}) bool

+ func (this *DownloadRequest) GoString() string

+ func (this *DownloadRequest) String() string

+ func (this *DownloadRequest) VerboseEqual(that interface{}) error

+ type DownloadResponse struct

+ Blob *Blob

+ func NewPopulatedDownloadResponse(r randyFile, easy bool) *DownloadResponse

+ func (*DownloadResponse) Descriptor() ([]byte, []int)

+ func (*DownloadResponse) ProtoMessage()

+ func (m *DownloadResponse) GetBlob() *Blob

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

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

+ func (m *DownloadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DownloadResponse) Reset()

+ func (m *DownloadResponse) Size() (n int)

+ func (m *DownloadResponse) Unmarshal(dAtA []byte) error

+ func (m *DownloadResponse) XXX_DiscardUnknown()

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

+ func (m *DownloadResponse) XXX_Merge(src proto.Message)

+ func (m *DownloadResponse) XXX_Size() int

+ func (m *DownloadResponse) XXX_Unmarshal(b []byte) error

+ func (this *DownloadResponse) Equal(that interface{}) bool

+ func (this *DownloadResponse) GoString() string

+ func (this *DownloadResponse) String() string

+ func (this *DownloadResponse) VerboseEqual(that interface{}) error

+ type EXTRASTYPE int32

+ const EXTRASTYPE_DISCOVERY

+ const EXTRASTYPE_IDENTIFY

+ const EXTRASTYPE_PUBSUB

+ func (EXTRASTYPE) EnumDescriptor() ([]byte, []int)

+ func (x EXTRASTYPE) String() string

+ type Empty struct

+ func NewPopulatedEmpty(r randyUtil, easy bool) *Empty

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

+ func (*Empty) ProtoMessage()

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

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

+ func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ func (m *Empty) XXX_DiscardUnknown()

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

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

+ func (m *Empty) XXX_Size() int

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

+ func (this *Empty) Equal(that interface{}) bool

+ func (this *Empty) GoString() string

+ func (this *Empty) String() string

+ func (this *Empty) VerboseEqual(that interface{}) error

+ type EnableExtrasRequest struct

+ ExtrasFeature EXTRASTYPE

+ func NewPopulatedEnableExtrasRequest(r randyNode, easy bool) *EnableExtrasRequest

+ func (*EnableExtrasRequest) Descriptor() ([]byte, []int)

+ func (*EnableExtrasRequest) ProtoMessage()

+ func (m *EnableExtrasRequest) GetExtrasFeature() EXTRASTYPE

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

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

+ func (m *EnableExtrasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EnableExtrasRequest) Reset()

+ func (m *EnableExtrasRequest) Size() (n int)

+ func (m *EnableExtrasRequest) Unmarshal(dAtA []byte) error

+ func (m *EnableExtrasRequest) XXX_DiscardUnknown()

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

+ func (m *EnableExtrasRequest) XXX_Merge(src proto.Message)

+ func (m *EnableExtrasRequest) XXX_Size() int

+ func (m *EnableExtrasRequest) XXX_Unmarshal(b []byte) error

+ func (this *EnableExtrasRequest) Equal(that interface{}) bool

+ func (this *EnableExtrasRequest) GoString() string

+ func (this *EnableExtrasRequest) String() string

+ func (this *EnableExtrasRequest) VerboseEqual(that interface{}) error

+ type FileAPIClient interface

+ DownloadFile func(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (FileAPI_DownloadFileClient, error)

+ UploadFile func(ctx context.Context, opts ...grpc.CallOption) (FileAPI_UploadFileClient, error)

+ func NewFileAPIClient(cc *grpc.ClientConn) FileAPIClient

+ type FileAPIServer interface

+ DownloadFile func(*DownloadRequest, FileAPI_DownloadFileServer) error

+ UploadFile func(FileAPI_UploadFileServer) error

+ type FileAPI_DownloadFileClient interface

+ Recv func() (*DownloadResponse, error)

+ type FileAPI_DownloadFileServer interface

+ Send func(*DownloadResponse) error

+ type FileAPI_UploadFileClient interface

+ CloseAndRecv func() (*PutResponse, error)

+ Send func(*UploadRequest) error

+ type FileAPI_UploadFileServer interface

+ Recv func() (*UploadRequest, error)

+ SendAndClose func(*PutResponse) error

+ type GCREQTYPE int32

+ const GCREQTYPE_GC_START

+ const GCREQTYPE_GC_STATUS

+ const GCREQTYPE_GC_STOP

+ func (GCREQTYPE) EnumDescriptor() ([]byte, []int)

+ func (x GCREQTYPE) String() string

+ type GetLinksRequest struct

+ Hash string

+ func NewPopulatedGetLinksRequest(r randyDag, easy bool) *GetLinksRequest

+ func (*GetLinksRequest) Descriptor() ([]byte, []int)

+ func (*GetLinksRequest) ProtoMessage()

+ func (m *GetLinksRequest) GetHash() string

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

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

+ func (m *GetLinksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetLinksRequest) Reset()

+ func (m *GetLinksRequest) Size() (n int)

+ func (m *GetLinksRequest) Unmarshal(dAtA []byte) error

+ func (m *GetLinksRequest) XXX_DiscardUnknown()

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

+ func (m *GetLinksRequest) XXX_Merge(src proto.Message)

+ func (m *GetLinksRequest) XXX_Size() int

+ func (m *GetLinksRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetLinksRequest) Equal(that interface{}) bool

+ func (this *GetLinksRequest) GoString() string

+ func (this *GetLinksRequest) String() string

+ func (this *GetLinksRequest) VerboseEqual(that interface{}) error

+ type GetLinksResponse struct

+ Links []*IPLDLink

+ func NewPopulatedGetLinksResponse(r randyDag, easy bool) *GetLinksResponse

+ func (*GetLinksResponse) Descriptor() ([]byte, []int)

+ func (*GetLinksResponse) ProtoMessage()

+ func (m *GetLinksResponse) GetLinks() []*IPLDLink

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

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

+ func (m *GetLinksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetLinksResponse) Reset()

+ func (m *GetLinksResponse) Size() (n int)

+ func (m *GetLinksResponse) Unmarshal(dAtA []byte) error

+ func (m *GetLinksResponse) XXX_DiscardUnknown()

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

+ func (m *GetLinksResponse) XXX_Merge(src proto.Message)

+ func (m *GetLinksResponse) XXX_Size() int

+ func (m *GetLinksResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetLinksResponse) Equal(that interface{}) bool

+ func (this *GetLinksResponse) GoString() string

+ func (this *GetLinksResponse) String() string

+ func (this *GetLinksResponse) VerboseEqual(that interface{}) error

+ type GetPeersResponse struct

+ PeerIDs []string

+ func NewPopulatedGetPeersResponse(r randyNode, easy bool) *GetPeersResponse

+ func (*GetPeersResponse) Descriptor() ([]byte, []int)

+ func (*GetPeersResponse) ProtoMessage()

+ func (m *GetPeersResponse) GetPeerIDs() []string

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

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

+ func (m *GetPeersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetPeersResponse) Reset()

+ func (m *GetPeersResponse) Size() (n int)

+ func (m *GetPeersResponse) Unmarshal(dAtA []byte) error

+ func (m *GetPeersResponse) XXX_DiscardUnknown()

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

+ func (m *GetPeersResponse) XXX_Merge(src proto.Message)

+ func (m *GetPeersResponse) XXX_Size() int

+ func (m *GetPeersResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetPeersResponse) Equal(that interface{}) bool

+ func (this *GetPeersResponse) GoString() string

+ func (this *GetPeersResponse) String() string

+ func (this *GetPeersResponse) VerboseEqual(that interface{}) error

+ type IPLDLink struct

+ Hash []byte

+ Name string

+ Size_ uint64

+ func NewPopulatedIPLDLink(r randyDag, easy bool) *IPLDLink

+ func (*IPLDLink) Descriptor() ([]byte, []int)

+ func (*IPLDLink) ProtoMessage()

+ func (m *IPLDLink) GetHash() []byte

+ func (m *IPLDLink) GetName() string

+ func (m *IPLDLink) GetSize_() uint64

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

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

+ func (m *IPLDLink) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IPLDLink) Reset()

+ func (m *IPLDLink) Size() (n int)

+ func (m *IPLDLink) Unmarshal(dAtA []byte) error

+ func (m *IPLDLink) XXX_DiscardUnknown()

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

+ func (m *IPLDLink) XXX_Merge(src proto.Message)

+ func (m *IPLDLink) XXX_Size() int

+ func (m *IPLDLink) XXX_Unmarshal(b []byte) error

+ func (this *IPLDLink) Equal(that interface{}) bool

+ func (this *IPLDLink) GoString() string

+ func (this *IPLDLink) String() string

+ func (this *IPLDLink) VerboseEqual(that interface{}) error

+ type IPLDNode struct

+ Data []byte

+ Links []*IPLDLink

+ func NewPopulatedIPLDNode(r randyDag, easy bool) *IPLDNode

+ func (*IPLDNode) Descriptor() ([]byte, []int)

+ func (*IPLDNode) ProtoMessage()

+ func (m *IPLDNode) GetData() []byte

+ func (m *IPLDNode) GetLinks() []*IPLDLink

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

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

+ func (m *IPLDNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IPLDNode) Reset()

+ func (m *IPLDNode) Size() (n int)

+ func (m *IPLDNode) Unmarshal(dAtA []byte) error

+ func (m *IPLDNode) XXX_DiscardUnknown()

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

+ func (m *IPLDNode) XXX_Merge(src proto.Message)

+ func (m *IPLDNode) XXX_Size() int

+ func (m *IPLDNode) XXX_Unmarshal(b []byte) error

+ func (this *IPLDNode) Equal(that interface{}) bool

+ func (this *IPLDNode) GoString() string

+ func (this *IPLDNode) String() string

+ func (this *IPLDNode) VerboseEqual(that interface{}) error

+ type IsConnectedRequest struct

+ PeerIDs []string

+ func NewPopulatedIsConnectedRequest(r randyNode, easy bool) *IsConnectedRequest

+ func (*IsConnectedRequest) Descriptor() ([]byte, []int)

+ func (*IsConnectedRequest) ProtoMessage()

+ func (m *IsConnectedRequest) GetPeerIDs() []string

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

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

+ func (m *IsConnectedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IsConnectedRequest) Reset()

+ func (m *IsConnectedRequest) Size() (n int)

+ func (m *IsConnectedRequest) Unmarshal(dAtA []byte) error

+ func (m *IsConnectedRequest) XXX_DiscardUnknown()

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

+ func (m *IsConnectedRequest) XXX_Merge(src proto.Message)

+ func (m *IsConnectedRequest) XXX_Size() int

+ func (m *IsConnectedRequest) XXX_Unmarshal(b []byte) error

+ func (this *IsConnectedRequest) Equal(that interface{}) bool

+ func (this *IsConnectedRequest) GoString() string

+ func (this *IsConnectedRequest) String() string

+ func (this *IsConnectedRequest) VerboseEqual(that interface{}) error

+ type IsConnectedResponse struct

+ Connected map[string]bool

+ func NewPopulatedIsConnectedResponse(r randyNode, easy bool) *IsConnectedResponse

+ func (*IsConnectedResponse) Descriptor() ([]byte, []int)

+ func (*IsConnectedResponse) ProtoMessage()

+ func (m *IsConnectedResponse) GetConnected() map[string]bool

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

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

+ func (m *IsConnectedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IsConnectedResponse) Reset()

+ func (m *IsConnectedResponse) Size() (n int)

+ func (m *IsConnectedResponse) Unmarshal(dAtA []byte) error

+ func (m *IsConnectedResponse) XXX_DiscardUnknown()

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

+ func (m *IsConnectedResponse) XXX_Merge(src proto.Message)

+ func (m *IsConnectedResponse) XXX_Size() int

+ func (m *IsConnectedResponse) XXX_Unmarshal(b []byte) error

+ func (this *IsConnectedResponse) Equal(that interface{}) bool

+ func (this *IsConnectedResponse) GoString() string

+ func (this *IsConnectedResponse) String() string

+ func (this *IsConnectedResponse) VerboseEqual(that interface{}) error

+ type KeystoreAPIClient interface

+ KeystoreDelete func(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)

+ KeystoreGet func(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)

+ KeystoreHas func(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)

+ KeystoreList func(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)

+ KeystorePut func(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)

+ func NewKeystoreAPIClient(cc *grpc.ClientConn) KeystoreAPIClient

+ type KeystoreAPIServer interface

+ KeystoreDelete func(context.Context, *KeystoreRequest) (*KeystoreResponse, error)

+ KeystoreGet func(context.Context, *KeystoreRequest) (*KeystoreResponse, error)

+ KeystoreHas func(context.Context, *KeystoreRequest) (*KeystoreResponse, error)

+ KeystoreList func(context.Context, *KeystoreRequest) (*KeystoreResponse, error)

+ KeystorePut func(context.Context, *KeystoreRequest) (*KeystoreResponse, error)

+ type KeystoreRequest struct

+ Name string

+ PrivateKey []byte

+ func NewPopulatedKeystoreRequest(r randyKeystore, easy bool) *KeystoreRequest

+ func (*KeystoreRequest) Descriptor() ([]byte, []int)

+ func (*KeystoreRequest) ProtoMessage()

+ func (m *KeystoreRequest) GetName() string

+ func (m *KeystoreRequest) GetPrivateKey() []byte

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

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

+ func (m *KeystoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *KeystoreRequest) Reset()

+ func (m *KeystoreRequest) Size() (n int)

+ func (m *KeystoreRequest) Unmarshal(dAtA []byte) error

+ func (m *KeystoreRequest) XXX_DiscardUnknown()

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

+ func (m *KeystoreRequest) XXX_Merge(src proto.Message)

+ func (m *KeystoreRequest) XXX_Size() int

+ func (m *KeystoreRequest) XXX_Unmarshal(b []byte) error

+ func (this *KeystoreRequest) Equal(that interface{}) bool

+ func (this *KeystoreRequest) GoString() string

+ func (this *KeystoreRequest) String() string

+ func (this *KeystoreRequest) VerboseEqual(that interface{}) error

+ type KeystoreResponse struct

+ KeyNames []string

+ PrivateKey []byte

+ Status string

+ func NewPopulatedKeystoreResponse(r randyKeystore, easy bool) *KeystoreResponse

+ func (*KeystoreResponse) Descriptor() ([]byte, []int)

+ func (*KeystoreResponse) ProtoMessage()

+ func (m *KeystoreResponse) GetKeyNames() []string

+ func (m *KeystoreResponse) GetPrivateKey() []byte

+ func (m *KeystoreResponse) GetStatus() string

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

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

+ func (m *KeystoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *KeystoreResponse) Reset()

+ func (m *KeystoreResponse) Size() (n int)

+ func (m *KeystoreResponse) Unmarshal(dAtA []byte) error

+ func (m *KeystoreResponse) XXX_DiscardUnknown()

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

+ func (m *KeystoreResponse) XXX_Merge(src proto.Message)

+ func (m *KeystoreResponse) XXX_Size() int

+ func (m *KeystoreResponse) XXX_Unmarshal(b []byte) error

+ func (this *KeystoreResponse) Equal(that interface{}) bool

+ func (this *KeystoreResponse) GoString() string

+ func (this *KeystoreResponse) String() string

+ func (this *KeystoreResponse) VerboseEqual(that interface{}) error

+ type ManageGCRequest struct

+ Type GCREQTYPE

+ func NewPopulatedManageGCRequest(r randyAdmin, easy bool) *ManageGCRequest

+ func (*ManageGCRequest) Descriptor() ([]byte, []int)

+ func (*ManageGCRequest) ProtoMessage()

+ func (m *ManageGCRequest) GetType() GCREQTYPE

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

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

+ func (m *ManageGCRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ManageGCRequest) Reset()

+ func (m *ManageGCRequest) Size() (n int)

+ func (m *ManageGCRequest) Unmarshal(dAtA []byte) error

+ func (m *ManageGCRequest) XXX_DiscardUnknown()

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

+ func (m *ManageGCRequest) XXX_Merge(src proto.Message)

+ func (m *ManageGCRequest) XXX_Size() int

+ func (m *ManageGCRequest) XXX_Unmarshal(b []byte) error

+ func (this *ManageGCRequest) Equal(that interface{}) bool

+ func (this *ManageGCRequest) GoString() string

+ func (this *ManageGCRequest) String() string

+ func (this *ManageGCRequest) VerboseEqual(that interface{}) error

+ type ManageGCResponse struct

+ Status string

+ func NewPopulatedManageGCResponse(r randyAdmin, easy bool) *ManageGCResponse

+ func (*ManageGCResponse) Descriptor() ([]byte, []int)

+ func (*ManageGCResponse) ProtoMessage()

+ func (m *ManageGCResponse) GetStatus() string

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

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

+ func (m *ManageGCResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ManageGCResponse) Reset()

+ func (m *ManageGCResponse) Size() (n int)

+ func (m *ManageGCResponse) Unmarshal(dAtA []byte) error

+ func (m *ManageGCResponse) XXX_DiscardUnknown()

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

+ func (m *ManageGCResponse) XXX_Merge(src proto.Message)

+ func (m *ManageGCResponse) XXX_Size() int

+ func (m *ManageGCResponse) XXX_Unmarshal(b []byte) error

+ func (this *ManageGCResponse) Equal(that interface{}) bool

+ func (this *ManageGCResponse) GoString() string

+ func (this *ManageGCResponse) String() string

+ func (this *ManageGCResponse) VerboseEqual(that interface{}) error

+ type NameSysAPIClient interface

+ NameSysPublish func(ctx context.Context, in *NameSysPublishRequest, opts ...grpc.CallOption) (*Empty, error)

+ NameSysResolve func(ctx context.Context, in *NameSysResolveRequest, opts ...grpc.CallOption) (*NameSysResolveResult, error)

+ NameSysResolveAsync func(ctx context.Context, in *NameSysResolveRequest, opts ...grpc.CallOption) (NameSysAPI_NameSysResolveAsyncClient, error)

+ func NewNameSysAPIClient(cc *grpc.ClientConn) NameSysAPIClient

+ type NameSysAPIServer interface

+ NameSysPublish func(context.Context, *NameSysPublishRequest) (*Empty, error)

+ NameSysResolve func(context.Context, *NameSysResolveRequest) (*NameSysResolveResult, error)

+ NameSysResolveAsync func(*NameSysResolveRequest, NameSysAPI_NameSysResolveAsyncServer) error

+ type NameSysAPI_NameSysResolveAsyncClient interface

+ Recv func() (*NameSysResolveResult, error)

+ type NameSysAPI_NameSysResolveAsyncServer interface

+ Send func(*NameSysResolveResult) error

+ type NameSysPublishRequest struct

+ Eol int32

+ PrivateKey []byte

+ Ttl int32

+ Value string

+ func NewPopulatedNameSysPublishRequest(r randyNamesys, easy bool) *NameSysPublishRequest

+ func (*NameSysPublishRequest) Descriptor() ([]byte, []int)

+ func (*NameSysPublishRequest) ProtoMessage()

+ func (m *NameSysPublishRequest) GetEol() int32

+ func (m *NameSysPublishRequest) GetPrivateKey() []byte

+ func (m *NameSysPublishRequest) GetTtl() int32

+ func (m *NameSysPublishRequest) GetValue() string

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

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

+ func (m *NameSysPublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NameSysPublishRequest) Reset()

+ func (m *NameSysPublishRequest) Size() (n int)

+ func (m *NameSysPublishRequest) Unmarshal(dAtA []byte) error

+ func (m *NameSysPublishRequest) XXX_DiscardUnknown()

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

+ func (m *NameSysPublishRequest) XXX_Merge(src proto.Message)

+ func (m *NameSysPublishRequest) XXX_Size() int

+ func (m *NameSysPublishRequest) XXX_Unmarshal(b []byte) error

+ func (this *NameSysPublishRequest) Equal(that interface{}) bool

+ func (this *NameSysPublishRequest) GoString() string

+ func (this *NameSysPublishRequest) String() string

+ func (this *NameSysPublishRequest) VerboseEqual(that interface{}) error

+ type NameSysResolveRequest struct

+ Depth uint32

+ DhtRecordCount uint32

+ DhtTimeout int32

+ Name string

+ func NewPopulatedNameSysResolveRequest(r randyNamesys, easy bool) *NameSysResolveRequest

+ func (*NameSysResolveRequest) Descriptor() ([]byte, []int)

+ func (*NameSysResolveRequest) ProtoMessage()

+ func (m *NameSysResolveRequest) GetDepth() uint32

+ func (m *NameSysResolveRequest) GetDhtRecordCount() uint32

+ func (m *NameSysResolveRequest) GetDhtTimeout() int32

+ func (m *NameSysResolveRequest) GetName() string

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

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

+ func (m *NameSysResolveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NameSysResolveRequest) Reset()

+ func (m *NameSysResolveRequest) Size() (n int)

+ func (m *NameSysResolveRequest) Unmarshal(dAtA []byte) error

+ func (m *NameSysResolveRequest) XXX_DiscardUnknown()

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

+ func (m *NameSysResolveRequest) XXX_Merge(src proto.Message)

+ func (m *NameSysResolveRequest) XXX_Size() int

+ func (m *NameSysResolveRequest) XXX_Unmarshal(b []byte) error

+ func (this *NameSysResolveRequest) Equal(that interface{}) bool

+ func (this *NameSysResolveRequest) GoString() string

+ func (this *NameSysResolveRequest) String() string

+ func (this *NameSysResolveRequest) VerboseEqual(that interface{}) error

+ type NameSysResolveResult struct

+ Error string

+ Path string

+ func NewPopulatedNameSysResolveResult(r randyNamesys, easy bool) *NameSysResolveResult

+ func (*NameSysResolveResult) Descriptor() ([]byte, []int)

+ func (*NameSysResolveResult) ProtoMessage()

+ func (m *NameSysResolveResult) GetError() string

+ func (m *NameSysResolveResult) GetPath() string

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

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

+ func (m *NameSysResolveResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NameSysResolveResult) Reset()

+ func (m *NameSysResolveResult) Size() (n int)

+ func (m *NameSysResolveResult) Unmarshal(dAtA []byte) error

+ func (m *NameSysResolveResult) XXX_DiscardUnknown()

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

+ func (m *NameSysResolveResult) XXX_Merge(src proto.Message)

+ func (m *NameSysResolveResult) XXX_Size() int

+ func (m *NameSysResolveResult) XXX_Unmarshal(b []byte) error

+ func (this *NameSysResolveResult) Equal(that interface{}) bool

+ func (this *NameSysResolveResult) GoString() string

+ func (this *NameSysResolveResult) String() string

+ func (this *NameSysResolveResult) VerboseEqual(that interface{}) error

+ type NewIPLDNodeRequest struct

+ Data []byte

+ HashFunc string

+ Links map[string]string

+ func NewPopulatedNewIPLDNodeRequest(r randyDag, easy bool) *NewIPLDNodeRequest

+ func (*NewIPLDNodeRequest) Descriptor() ([]byte, []int)

+ func (*NewIPLDNodeRequest) ProtoMessage()

+ func (m *NewIPLDNodeRequest) GetData() []byte

+ func (m *NewIPLDNodeRequest) GetHashFunc() string

+ func (m *NewIPLDNodeRequest) GetLinks() map[string]string

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

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

+ func (m *NewIPLDNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NewIPLDNodeRequest) Reset()

+ func (m *NewIPLDNodeRequest) Size() (n int)

+ func (m *NewIPLDNodeRequest) Unmarshal(dAtA []byte) error

+ func (m *NewIPLDNodeRequest) XXX_DiscardUnknown()

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

+ func (m *NewIPLDNodeRequest) XXX_Merge(src proto.Message)

+ func (m *NewIPLDNodeRequest) XXX_Size() int

+ func (m *NewIPLDNodeRequest) XXX_Unmarshal(b []byte) error

+ func (this *NewIPLDNodeRequest) Equal(that interface{}) bool

+ func (this *NewIPLDNodeRequest) GoString() string

+ func (this *NewIPLDNodeRequest) String() string

+ func (this *NewIPLDNodeRequest) VerboseEqual(that interface{}) error

+ type NodeAPIClient interface

+ Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*Empty, error)

+ DisableExtras func(ctx context.Context, in *DisableExtrasRequest, opts ...grpc.CallOption) (*Empty, error)

+ Disconnect func(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error)

+ EnableExtras func(ctx context.Context, in *EnableExtrasRequest, opts ...grpc.CallOption) (*Empty, error)

+ GetPeers func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetPeersResponse, error)

+ IsConnected func(ctx context.Context, in *IsConnectedRequest, opts ...grpc.CallOption) (*IsConnectedResponse, error)

+ func NewNodeAPIClient(cc *grpc.ClientConn) NodeAPIClient

+ type NodeAPIServer interface

+ Connect func(context.Context, *ConnectRequest) (*Empty, error)

+ DisableExtras func(context.Context, *DisableExtrasRequest) (*Empty, error)

+ Disconnect func(context.Context, *DisconnectRequest) (*DisconnectResponse, error)

+ EnableExtras func(context.Context, *EnableExtrasRequest) (*Empty, error)

+ GetPeers func(context.Context, *Empty) (*GetPeersResponse, error)

+ IsConnected func(context.Context, *IsConnectedRequest) (*IsConnectedResponse, error)

+ type PubSubAPIClient interface

+ PubSubGetTopics func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PubSubTopicsResponse, error)

+ PubSubListPeers func(ctx context.Context, in *PubSubListPeersRequest, opts ...grpc.CallOption) (*PubSubListPeersResponse, error)

+ PubSubPublish func(ctx context.Context, opts ...grpc.CallOption) (PubSubAPI_PubSubPublishClient, error)

+ PubSubSubscribe func(ctx context.Context, in *PubSubSubscribeRequest, opts ...grpc.CallOption) (PubSubAPI_PubSubSubscribeClient, error)

+ func NewPubSubAPIClient(cc *grpc.ClientConn) PubSubAPIClient

+ type PubSubAPIServer interface

+ PubSubGetTopics func(context.Context, *Empty) (*PubSubTopicsResponse, error)

+ PubSubListPeers func(context.Context, *PubSubListPeersRequest) (*PubSubListPeersResponse, error)

+ PubSubPublish func(PubSubAPI_PubSubPublishServer) error

+ PubSubSubscribe func(*PubSubSubscribeRequest, PubSubAPI_PubSubSubscribeServer) error

+ type PubSubAPI_PubSubPublishClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*PubSubPublishRequest) error

+ type PubSubAPI_PubSubPublishServer interface

+ Recv func() (*PubSubPublishRequest, error)

+ SendAndClose func(*Empty) error

+ type PubSubAPI_PubSubSubscribeClient interface

+ Recv func() (*PubSubMessageResponse, error)

+ type PubSubAPI_PubSubSubscribeServer interface

+ Send func(*PubSubMessageResponse) error

+ type PubSubListPeersRequest struct

+ Topics []string

+ func NewPopulatedPubSubListPeersRequest(r randyPubsub, easy bool) *PubSubListPeersRequest

+ func (*PubSubListPeersRequest) Descriptor() ([]byte, []int)

+ func (*PubSubListPeersRequest) ProtoMessage()

+ func (m *PubSubListPeersRequest) GetTopics() []string

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

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

+ func (m *PubSubListPeersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubListPeersRequest) Reset()

+ func (m *PubSubListPeersRequest) Size() (n int)

+ func (m *PubSubListPeersRequest) Unmarshal(dAtA []byte) error

+ func (m *PubSubListPeersRequest) XXX_DiscardUnknown()

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

+ func (m *PubSubListPeersRequest) XXX_Merge(src proto.Message)

+ func (m *PubSubListPeersRequest) XXX_Size() int

+ func (m *PubSubListPeersRequest) XXX_Unmarshal(b []byte) error

+ func (this *PubSubListPeersRequest) Equal(that interface{}) bool

+ func (this *PubSubListPeersRequest) GoString() string

+ func (this *PubSubListPeersRequest) String() string

+ func (this *PubSubListPeersRequest) VerboseEqual(that interface{}) error

+ type PubSubListPeersResponse struct

+ Peers []*PubSubListPeersResponse_Peer

+ func NewPopulatedPubSubListPeersResponse(r randyPubsub, easy bool) *PubSubListPeersResponse

+ func (*PubSubListPeersResponse) Descriptor() ([]byte, []int)

+ func (*PubSubListPeersResponse) ProtoMessage()

+ func (m *PubSubListPeersResponse) GetPeers() []*PubSubListPeersResponse_Peer

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

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

+ func (m *PubSubListPeersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubListPeersResponse) Reset()

+ func (m *PubSubListPeersResponse) Size() (n int)

+ func (m *PubSubListPeersResponse) Unmarshal(dAtA []byte) error

+ func (m *PubSubListPeersResponse) XXX_DiscardUnknown()

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

+ func (m *PubSubListPeersResponse) XXX_Merge(src proto.Message)

+ func (m *PubSubListPeersResponse) XXX_Size() int

+ func (m *PubSubListPeersResponse) XXX_Unmarshal(b []byte) error

+ func (this *PubSubListPeersResponse) Equal(that interface{}) bool

+ func (this *PubSubListPeersResponse) GoString() string

+ func (this *PubSubListPeersResponse) String() string

+ func (this *PubSubListPeersResponse) VerboseEqual(that interface{}) error

+ type PubSubListPeersResponse_Peer struct

+ PeerID string

+ Topic string

+ func NewPopulatedPubSubListPeersResponse_Peer(r randyPubsub, easy bool) *PubSubListPeersResponse_Peer

+ func (*PubSubListPeersResponse_Peer) Descriptor() ([]byte, []int)

+ func (*PubSubListPeersResponse_Peer) ProtoMessage()

+ func (m *PubSubListPeersResponse_Peer) GetPeerID() string

+ func (m *PubSubListPeersResponse_Peer) GetTopic() string

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

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

+ func (m *PubSubListPeersResponse_Peer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubListPeersResponse_Peer) Reset()

+ func (m *PubSubListPeersResponse_Peer) Size() (n int)

+ func (m *PubSubListPeersResponse_Peer) Unmarshal(dAtA []byte) error

+ func (m *PubSubListPeersResponse_Peer) XXX_DiscardUnknown()

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

+ func (m *PubSubListPeersResponse_Peer) XXX_Merge(src proto.Message)

+ func (m *PubSubListPeersResponse_Peer) XXX_Size() int

+ func (m *PubSubListPeersResponse_Peer) XXX_Unmarshal(b []byte) error

+ func (this *PubSubListPeersResponse_Peer) Equal(that interface{}) bool

+ func (this *PubSubListPeersResponse_Peer) GoString() string

+ func (this *PubSubListPeersResponse_Peer) String() string

+ func (this *PubSubListPeersResponse_Peer) VerboseEqual(that interface{}) error

+ type PubSubMessageResponse struct

+ Data []byte

+ From []byte

+ Key []byte

+ Seqno []byte

+ Signature []byte

+ TopicIDs []string

+ func NewPopulatedPubSubMessageResponse(r randyPubsub, easy bool) *PubSubMessageResponse

+ func (*PubSubMessageResponse) Descriptor() ([]byte, []int)

+ func (*PubSubMessageResponse) ProtoMessage()

+ func (m *PubSubMessageResponse) GetData() []byte

+ func (m *PubSubMessageResponse) GetFrom() []byte

+ func (m *PubSubMessageResponse) GetKey() []byte

+ func (m *PubSubMessageResponse) GetSeqno() []byte

+ func (m *PubSubMessageResponse) GetSignature() []byte

+ func (m *PubSubMessageResponse) GetTopicIDs() []string

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

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

+ func (m *PubSubMessageResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubMessageResponse) Reset()

+ func (m *PubSubMessageResponse) Size() (n int)

+ func (m *PubSubMessageResponse) Unmarshal(dAtA []byte) error

+ func (m *PubSubMessageResponse) XXX_DiscardUnknown()

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

+ func (m *PubSubMessageResponse) XXX_Merge(src proto.Message)

+ func (m *PubSubMessageResponse) XXX_Size() int

+ func (m *PubSubMessageResponse) XXX_Unmarshal(b []byte) error

+ func (this *PubSubMessageResponse) Equal(that interface{}) bool

+ func (this *PubSubMessageResponse) GoString() string

+ func (this *PubSubMessageResponse) String() string

+ func (this *PubSubMessageResponse) VerboseEqual(that interface{}) error

+ type PubSubPublishRequest struct

+ Advertise bool

+ Data []byte

+ Topic string

+ func NewPopulatedPubSubPublishRequest(r randyPubsub, easy bool) *PubSubPublishRequest

+ func (*PubSubPublishRequest) Descriptor() ([]byte, []int)

+ func (*PubSubPublishRequest) ProtoMessage()

+ func (m *PubSubPublishRequest) GetAdvertise() bool

+ func (m *PubSubPublishRequest) GetData() []byte

+ func (m *PubSubPublishRequest) GetTopic() string

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

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

+ func (m *PubSubPublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubPublishRequest) Reset()

+ func (m *PubSubPublishRequest) Size() (n int)

+ func (m *PubSubPublishRequest) Unmarshal(dAtA []byte) error

+ func (m *PubSubPublishRequest) XXX_DiscardUnknown()

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

+ func (m *PubSubPublishRequest) XXX_Merge(src proto.Message)

+ func (m *PubSubPublishRequest) XXX_Size() int

+ func (m *PubSubPublishRequest) XXX_Unmarshal(b []byte) error

+ func (this *PubSubPublishRequest) Equal(that interface{}) bool

+ func (this *PubSubPublishRequest) GoString() string

+ func (this *PubSubPublishRequest) String() string

+ func (this *PubSubPublishRequest) VerboseEqual(that interface{}) error

+ type PubSubSubscribeRequest struct

+ Discover bool

+ Topic string

+ func NewPopulatedPubSubSubscribeRequest(r randyPubsub, easy bool) *PubSubSubscribeRequest

+ func (*PubSubSubscribeRequest) Descriptor() ([]byte, []int)

+ func (*PubSubSubscribeRequest) ProtoMessage()

+ func (m *PubSubSubscribeRequest) GetDiscover() bool

+ func (m *PubSubSubscribeRequest) GetTopic() string

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

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

+ func (m *PubSubSubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubSubscribeRequest) Reset()

+ func (m *PubSubSubscribeRequest) Size() (n int)

+ func (m *PubSubSubscribeRequest) Unmarshal(dAtA []byte) error

+ func (m *PubSubSubscribeRequest) XXX_DiscardUnknown()

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

+ func (m *PubSubSubscribeRequest) XXX_Merge(src proto.Message)

+ func (m *PubSubSubscribeRequest) XXX_Size() int

+ func (m *PubSubSubscribeRequest) XXX_Unmarshal(b []byte) error

+ func (this *PubSubSubscribeRequest) Equal(that interface{}) bool

+ func (this *PubSubSubscribeRequest) GoString() string

+ func (this *PubSubSubscribeRequest) String() string

+ func (this *PubSubSubscribeRequest) VerboseEqual(that interface{}) error

+ type PubSubTopicsResponse struct

+ Names []string

+ func NewPopulatedPubSubTopicsResponse(r randyPubsub, easy bool) *PubSubTopicsResponse

+ func (*PubSubTopicsResponse) Descriptor() ([]byte, []int)

+ func (*PubSubTopicsResponse) ProtoMessage()

+ func (m *PubSubTopicsResponse) GetNames() []string

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

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

+ func (m *PubSubTopicsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubTopicsResponse) Reset()

+ func (m *PubSubTopicsResponse) Size() (n int)

+ func (m *PubSubTopicsResponse) Unmarshal(dAtA []byte) error

+ func (m *PubSubTopicsResponse) XXX_DiscardUnknown()

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

+ func (m *PubSubTopicsResponse) XXX_Merge(src proto.Message)

+ func (m *PubSubTopicsResponse) XXX_Size() int

+ func (m *PubSubTopicsResponse) XXX_Unmarshal(b []byte) error

+ func (this *PubSubTopicsResponse) Equal(that interface{}) bool

+ func (this *PubSubTopicsResponse) GoString() string

+ func (this *PubSubTopicsResponse) String() string

+ func (this *PubSubTopicsResponse) VerboseEqual(that interface{}) error

+ type PutResponse struct

+ Hash string

+ func NewPopulatedPutResponse(r randyUtil, easy bool) *PutResponse

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

+ func (*PutResponse) ProtoMessage()

+ func (m *PutResponse) GetHash() string

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

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

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

+ func (m *PutResponse) Reset()

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

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

+ func (m *PutResponse) XXX_DiscardUnknown()

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

+ func (m *PutResponse) XXX_Merge(src proto.Message)

+ func (m *PutResponse) XXX_Size() int

+ func (m *PutResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *PutResponse) GoString() string

+ func (this *PutResponse) String() string

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

+ type REFREQOPTS int32

+ const REFREQOPTS_REF_FORCE

+ func (REFREQOPTS) EnumDescriptor() ([]byte, []int)

+ func (x REFREQOPTS) String() string

+ type REFREQTYPE int32

+ const REFREQTYPE_REF_DELETE

+ const REFREQTYPE_REF_GET_COUNT

+ func (REFREQTYPE) EnumDescriptor() ([]byte, []int)

+ func (x REFREQTYPE) String() string

+ type RefCountRequest struct

+ Cids []string

+ Limit int64

+ func NewPopulatedRefCountRequest(r randyAdmin, easy bool) *RefCountRequest

+ func (*RefCountRequest) Descriptor() ([]byte, []int)

+ func (*RefCountRequest) ProtoMessage()

+ func (m *RefCountRequest) GetCids() []string

+ func (m *RefCountRequest) GetLimit() int64

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

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

+ func (m *RefCountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RefCountRequest) Reset()

+ func (m *RefCountRequest) Size() (n int)

+ func (m *RefCountRequest) Unmarshal(dAtA []byte) error

+ func (m *RefCountRequest) XXX_DiscardUnknown()

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

+ func (m *RefCountRequest) XXX_Merge(src proto.Message)

+ func (m *RefCountRequest) XXX_Size() int

+ func (m *RefCountRequest) XXX_Unmarshal(b []byte) error

+ func (this *RefCountRequest) Equal(that interface{}) bool

+ func (this *RefCountRequest) GoString() string

+ func (this *RefCountRequest) String() string

+ func (this *RefCountRequest) VerboseEqual(that interface{}) error

+ type RefCountResponse struct

+ Cids map[string]int64

+ func NewPopulatedRefCountResponse(r randyAdmin, easy bool) *RefCountResponse

+ func (*RefCountResponse) Descriptor() ([]byte, []int)

+ func (*RefCountResponse) ProtoMessage()

+ func (m *RefCountResponse) GetCids() map[string]int64

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

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

+ func (m *RefCountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RefCountResponse) Reset()

+ func (m *RefCountResponse) Size() (n int)

+ func (m *RefCountResponse) Unmarshal(dAtA []byte) error

+ func (m *RefCountResponse) XXX_DiscardUnknown()

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

+ func (m *RefCountResponse) XXX_Merge(src proto.Message)

+ func (m *RefCountResponse) XXX_Size() int

+ func (m *RefCountResponse) XXX_Unmarshal(b []byte) error

+ func (this *RefCountResponse) Equal(that interface{}) bool

+ func (this *RefCountResponse) GoString() string

+ func (this *RefCountResponse) String() string

+ func (this *RefCountResponse) VerboseEqual(that interface{}) error

+ type StatusAPIClient interface

+ Status func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusResponse, error)

+ Version func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionResponse, error)

+ func NewStatusAPIClient(cc *grpc.ClientConn) StatusAPIClient

+ type StatusAPIServer interface

+ Status func(context.Context, *Empty) (*StatusResponse, error)

+ Version func(context.Context, *Empty) (*VersionResponse, error)

+ type StatusResponse struct

+ Host string

+ Status APISTATUS

+ func NewPopulatedStatusResponse(r randyStatus, easy bool) *StatusResponse

+ func (*StatusResponse) Descriptor() ([]byte, []int)

+ func (*StatusResponse) ProtoMessage()

+ func (m *StatusResponse) GetHost() string

+ func (m *StatusResponse) GetStatus() APISTATUS

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

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

+ func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StatusResponse) Reset()

+ func (m *StatusResponse) Size() (n int)

+ func (m *StatusResponse) Unmarshal(dAtA []byte) error

+ func (m *StatusResponse) XXX_DiscardUnknown()

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

+ func (m *StatusResponse) XXX_Merge(src proto.Message)

+ func (m *StatusResponse) XXX_Size() int

+ func (m *StatusResponse) XXX_Unmarshal(b []byte) error

+ func (this *StatusResponse) Equal(that interface{}) bool

+ func (this *StatusResponse) GoString() string

+ func (this *StatusResponse) String() string

+ func (this *StatusResponse) VerboseEqual(that interface{}) error

+ type UnimplementedAdminAPIServer struct

+ func (*UnimplementedAdminAPIServer) Blockstore(ctx context.Context, req *BlockstoreRequest) (*BlockstoreResponse, error)

+ func (*UnimplementedAdminAPIServer) ManageGC(ctx context.Context, req *ManageGCRequest) (*ManageGCResponse, error)

+ func (*UnimplementedAdminAPIServer) RefCount(ctx context.Context, req *RefCountRequest) (*RefCountResponse, error)

+ type UnimplementedDagAPIServer struct

+ func (*UnimplementedDagAPIServer) AddLinksToNode(ctx context.Context, req *AddLinksRequest) (*DagPutResponse, error)

+ func (*UnimplementedDagAPIServer) DagGet(ctx context.Context, req *DagGetRequest) (*DagGetResponse, error)

+ func (*UnimplementedDagAPIServer) DagPut(ctx context.Context, req *DagPutRequest) (*DagPutResponse, error)

+ func (*UnimplementedDagAPIServer) GetLinks(ctx context.Context, req *GetLinksRequest) (*GetLinksResponse, error)

+ func (*UnimplementedDagAPIServer) NewIPLDNode(ctx context.Context, req *NewIPLDNodeRequest) (*DagPutResponse, error)

+ type UnimplementedFileAPIServer struct

+ func (*UnimplementedFileAPIServer) DownloadFile(req *DownloadRequest, srv FileAPI_DownloadFileServer) error

+ func (*UnimplementedFileAPIServer) UploadFile(srv FileAPI_UploadFileServer) error

+ type UnimplementedKeystoreAPIServer struct

+ func (*UnimplementedKeystoreAPIServer) KeystoreDelete(ctx context.Context, req *KeystoreRequest) (*KeystoreResponse, error)

+ func (*UnimplementedKeystoreAPIServer) KeystoreGet(ctx context.Context, req *KeystoreRequest) (*KeystoreResponse, error)

+ func (*UnimplementedKeystoreAPIServer) KeystoreHas(ctx context.Context, req *KeystoreRequest) (*KeystoreResponse, error)

+ func (*UnimplementedKeystoreAPIServer) KeystoreList(ctx context.Context, req *KeystoreRequest) (*KeystoreResponse, error)

+ func (*UnimplementedKeystoreAPIServer) KeystorePut(ctx context.Context, req *KeystoreRequest) (*KeystoreResponse, error)

+ type UnimplementedNameSysAPIServer struct

+ func (*UnimplementedNameSysAPIServer) NameSysPublish(ctx context.Context, req *NameSysPublishRequest) (*Empty, error)

+ func (*UnimplementedNameSysAPIServer) NameSysResolve(ctx context.Context, req *NameSysResolveRequest) (*NameSysResolveResult, error)

+ func (*UnimplementedNameSysAPIServer) NameSysResolveAsync(req *NameSysResolveRequest, srv NameSysAPI_NameSysResolveAsyncServer) error

+ type UnimplementedNodeAPIServer struct

+ func (*UnimplementedNodeAPIServer) Connect(ctx context.Context, req *ConnectRequest) (*Empty, error)

+ func (*UnimplementedNodeAPIServer) DisableExtras(ctx context.Context, req *DisableExtrasRequest) (*Empty, error)

+ func (*UnimplementedNodeAPIServer) Disconnect(ctx context.Context, req *DisconnectRequest) (*DisconnectResponse, error)

+ func (*UnimplementedNodeAPIServer) EnableExtras(ctx context.Context, req *EnableExtrasRequest) (*Empty, error)

+ func (*UnimplementedNodeAPIServer) GetPeers(ctx context.Context, req *Empty) (*GetPeersResponse, error)

+ func (*UnimplementedNodeAPIServer) IsConnected(ctx context.Context, req *IsConnectedRequest) (*IsConnectedResponse, error)

+ type UnimplementedPubSubAPIServer struct

+ func (*UnimplementedPubSubAPIServer) PubSubGetTopics(ctx context.Context, req *Empty) (*PubSubTopicsResponse, error)

+ func (*UnimplementedPubSubAPIServer) PubSubListPeers(ctx context.Context, req *PubSubListPeersRequest) (*PubSubListPeersResponse, error)

+ func (*UnimplementedPubSubAPIServer) PubSubPublish(srv PubSubAPI_PubSubPublishServer) error

+ func (*UnimplementedPubSubAPIServer) PubSubSubscribe(req *PubSubSubscribeRequest, srv PubSubAPI_PubSubSubscribeServer) error

+ type UnimplementedStatusAPIServer struct

+ func (*UnimplementedStatusAPIServer) Status(ctx context.Context, req *Empty) (*StatusResponse, error)

+ func (*UnimplementedStatusAPIServer) Version(ctx context.Context, req *Empty) (*VersionResponse, error)

+ type UploadOptions struct

+ Chunker string

+ Layout string

+ MultiHash string

+ func NewPopulatedUploadOptions(r randyFile, easy bool) *UploadOptions

+ func (*UploadOptions) Descriptor() ([]byte, []int)

+ func (*UploadOptions) ProtoMessage()

+ func (m *UploadOptions) GetChunker() string

+ func (m *UploadOptions) GetLayout() string

+ func (m *UploadOptions) GetMultiHash() string

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

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

+ func (m *UploadOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UploadOptions) Reset()

+ func (m *UploadOptions) Size() (n int)

+ func (m *UploadOptions) Unmarshal(dAtA []byte) error

+ func (m *UploadOptions) XXX_DiscardUnknown()

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

+ func (m *UploadOptions) XXX_Merge(src proto.Message)

+ func (m *UploadOptions) XXX_Size() int

+ func (m *UploadOptions) XXX_Unmarshal(b []byte) error

+ func (this *UploadOptions) Equal(that interface{}) bool

+ func (this *UploadOptions) GoString() string

+ func (this *UploadOptions) String() string

+ func (this *UploadOptions) VerboseEqual(that interface{}) error

+ type UploadRequest struct

+ Blob *Blob

+ Options *UploadOptions

+ func NewPopulatedUploadRequest(r randyFile, easy bool) *UploadRequest

+ func (*UploadRequest) Descriptor() ([]byte, []int)

+ func (*UploadRequest) ProtoMessage()

+ func (m *UploadRequest) GetBlob() *Blob

+ func (m *UploadRequest) GetOptions() *UploadOptions

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

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

+ func (m *UploadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UploadRequest) Reset()

+ func (m *UploadRequest) Size() (n int)

+ func (m *UploadRequest) Unmarshal(dAtA []byte) error

+ func (m *UploadRequest) XXX_DiscardUnknown()

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

+ func (m *UploadRequest) XXX_Merge(src proto.Message)

+ func (m *UploadRequest) XXX_Size() int

+ func (m *UploadRequest) XXX_Unmarshal(b []byte) error

+ func (this *UploadRequest) Equal(that interface{}) bool

+ func (this *UploadRequest) GoString() string

+ func (this *UploadRequest) String() string

+ func (this *UploadRequest) VerboseEqual(that interface{}) error

+ type VersionResponse struct

+ Version string

+ func NewPopulatedVersionResponse(r randyStatus, easy bool) *VersionResponse

+ func (*VersionResponse) Descriptor() ([]byte, []int)

+ func (*VersionResponse) ProtoMessage()

+ func (m *VersionResponse) GetVersion() string

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

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

+ func (m *VersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VersionResponse) Reset()

+ func (m *VersionResponse) Size() (n int)

+ func (m *VersionResponse) Unmarshal(dAtA []byte) error

+ func (m *VersionResponse) XXX_DiscardUnknown()

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

+ func (m *VersionResponse) XXX_Merge(src proto.Message)

+ func (m *VersionResponse) XXX_Size() int

+ func (m *VersionResponse) XXX_Unmarshal(b []byte) error

+ func (this *VersionResponse) Equal(that interface{}) bool

+ func (this *VersionResponse) GoString() string

+ func (this *VersionResponse) String() string

+ func (this *VersionResponse) VerboseEqual(that interface{}) error

v1.0.0-rc4

Oct 12, 2019

v1.0.0-rc3

Sep 24, 2019

v1.0.0-rc2

Sep 24, 2019

v1.0.0-rc1

Sep 14, 2019

Other modules containing this package

github.com/RTradeLtd/TxPB/v2

github.com/RTradeLtd/TxPB/v3

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL