pb

package

Go to main page

Versions in this module

v3

v3.4.2

May 29, 2020

v3.2.4

May 18, 2020

Changes in this version

type SimpleGRPCConnectionProvider

+ func (s *SimpleGRPCConnectionProvider) SetInitConnectionTimeout(d time.Duration)

v3.2.4-rc1

Apr 20, 2020

v3.2.3

Apr 17, 2020

Changes in this version

type BSREQTYPE

+ const BSREQTYPE_BS_HAS

+ const BSREQTYPE_BS_HASH_ON_READ_DISABLE

+ const BSREQTYPE_BS_HASH_ON_READ_ENABLE

+ type DAGService struct

+ func NewDAGService(client NodeAPIClient) *DAGService

+ func (d *DAGService) Add(ctx context.Context, n ipld.Node) error

+ func (d *DAGService) AddMany(ctx context.Context, ns []ipld.Node) error

+ func (d *DAGService) Get(ctx context.Context, c cid.Cid) (ipld.Node, error)

+ func (d *DAGService) GetMany(ctx context.Context, cs []cid.Cid) <-chan *ipld.NodeOption

+ func (d *DAGService) Remove(ctx context.Context, c cid.Cid) error

+ func (d *DAGService) RemoveMany(ctx context.Context, cs []cid.Cid) error

v3.2.3-rc2

Apr 14, 2020

v3.2.3-rc1

Apr 14, 2020

v3.2.2

Mar 31, 2020

Changes in this version

type DAGREQTYPE

+ const DAGREQTYPE_DAG_STAT

type DagResponse

+ NodeStats map[string]*IPLDStat

+ func (m *DagResponse) GetNodeStats() map[string]*IPLDStat

+ type IPLDStat struct

+ BlockSize int64

+ CumulativeSize int64

+ DataSize int64

+ LinkSize int64

+ NumLinks int64

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

+ func (*IPLDStat) ProtoMessage()

+ func (m *IPLDStat) GetBlockSize() int64

+ func (m *IPLDStat) GetCumulativeSize() int64

+ func (m *IPLDStat) GetDataSize() int64

+ func (m *IPLDStat) GetLinkSize() int64

+ func (m *IPLDStat) GetNumLinks() int64

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

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

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

+ func (m *IPLDStat) Reset()

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

+ func (m *IPLDStat) String() string

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

+ func (m *IPLDStat) XXX_DiscardUnknown()

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

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

+ func (m *IPLDStat) XXX_Size() int

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

v3.2.2-rc1

Mar 30, 2020

v3.2.1

Mar 28, 2020

Changes in this version

type BSREQTYPE

+ const BSREQTYPE_BS_GET_ALL

+ const BSREQTYPE_BS_GET_STATS

type Block

+ Size_ int64

+ func (m *Block) GetSize_() int64

type NodeAPIClient

+ BlockstoreStream func(ctx context.Context, opts ...grpc.CallOption) (NodeAPI_BlockstoreStreamClient, error)

type NodeAPIServer

+ BlockstoreStream func(NodeAPI_BlockstoreStreamServer) error

+ type NodeAPI_BlockstoreStreamClient interface

+ Recv func() (*BlockstoreResponse, error)

+ Send func(*BlockstoreRequest) error

+ type NodeAPI_BlockstoreStreamServer interface

+ Recv func() (*BlockstoreRequest, error)

+ Send func(*BlockstoreResponse) error

type UnimplementedNodeAPIServer

+ func (*UnimplementedNodeAPIServer) BlockstoreStream(srv NodeAPI_BlockstoreStreamServer) error

v3.2.1-rc1

Mar 27, 2020

v3.2.0

Mar 24, 2020

Changes in this version

+ var ErrConnectToSelf = errors.New("connection to self not allowed")

+ func NewReplicatorClientConstructor(myPrivateKey libcryto.PrivKey, server *AddrInfo, ...) (ReplicatorClient, Close, error)

+ type AddPeer func(id peer.ID, ma multiaddr.Multiaddr)

+ type Close func() error

+ type GRPCConnectionProvider interface

+ ConnectionToServer func(a *AddrInfo) (conn *grpc.ClientConn, err error)

type Replication

+ func NewReplication() *Replication

+ type SimpleGRPCConnectionProvider struct

+ func NewSimpleConnectionProvider(pk libcryto.PrivKey, addPeer AddPeer, logger *zap.Logger) (*SimpleGRPCConnectionProvider, error)

+ func (s *SimpleGRPCConnectionProvider) ConnectionToServer(a *AddrInfo) (*grpc.ClientConn, error)

v3.1.1

Mar 3, 2020

Changes in this version

type Blob

+ RangeEnd uint64

+ RangeStart uint64

+ func (m *Blob) GetRangeEnd() uint64

+ func (m *Blob) GetRangeStart() uint64

type DownloadRequest

+ RangeEnd uint64

+ RangeStart uint64

+ func (m *DownloadRequest) GetRangeEnd() uint64

+ func (m *DownloadRequest) GetRangeStart() uint64

v3.1.0

Mar 2, 2020

Changes in this version

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

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

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

+ func RegisterReplicatorServer(s *grpc.Server, srv ReplicatorServer)

+ type AddrInfo struct

+ AddrsBytes [][]byte

+ GrpcPort int32

+ IdBytes []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewAddrInfoFromHost(h HostInfo, gport int32) (*AddrInfo, error)

+ func ServerSourcesToAddrInfos(ss []*ServerSource) []*AddrInfo

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

+ func (*AddrInfo) ProtoMessage()

+ func (a *AddrInfo) AddMultiAddr(m multiaddr.Multiaddr) error

+ func (a *AddrInfo) GetID() (peer.ID, error)

+ func (a *AddrInfo) GetMultiAddrs() ([]multiaddr.Multiaddr, error)

+ func (a *AddrInfo) SetID(id peer.ID)

+ func (m *AddrInfo) GetAddrsBytes() [][]byte

+ func (m *AddrInfo) GetGrpcPort() int32

+ func (m *AddrInfo) GetIdBytes() []byte

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

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

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

+ func (m *AddrInfo) Reset()

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

+ func (m *AddrInfo) String() string

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

+ func (m *AddrInfo) XXX_DiscardUnknown()

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

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

+ func (m *AddrInfo) XXX_Size() int

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

+ type HostInfo interface

+ Addrs func() []multiaddr.Multiaddr

+ ID func() peer.ID

+ type Replication struct

+ CidsBytes [][]byte

+ Header string

+ RefreshIntervalSeconds int32

+ ReplicationFactor int32

+ ServerDownDelaySeconds int32

+ Servers []*ServerSource

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func New() *Replication

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

+ func (*Replication) ProtoMessage()

+ func (m *Replication) GetCidsBytes() [][]byte

+ func (m *Replication) GetHeader() string

+ func (m *Replication) GetRefreshIntervalSeconds() int32

+ func (m *Replication) GetReplicationFactor() int32

+ func (m *Replication) GetServerDownDelaySeconds() int32

+ func (m *Replication) GetServers() []*ServerSource

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

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

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

+ func (m *Replication) Reset()

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

+ func (m *Replication) String() string

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

+ func (m *Replication) XXX_DiscardUnknown()

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

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

+ func (m *Replication) XXX_Size() int

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

+ func (r *Replication) AddCIDs(cids ...cid.Cid) error

+ func (r *Replication) GetCIDs() ([]cid.Cid, error)

+ func (r *Replication) GetHeaderString(strict bool) (string, error)

+ func (r *Replication) Valid(strict bool) error

+ type ReplicationStatus struct

+ CurrentVersion int64

+ IsActive bool

+ Ok bool

+ TargetVersion int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReplicationStatus) ProtoMessage()

+ func (m *ReplicationStatus) GetCurrentVersion() int64

+ func (m *ReplicationStatus) GetIsActive() bool

+ func (m *ReplicationStatus) GetOk() bool

+ func (m *ReplicationStatus) GetTargetVersion() int64

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

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

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

+ func (m *ReplicationStatus) Reset()

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

+ func (m *ReplicationStatus) String() string

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

+ func (m *ReplicationStatus) XXX_DiscardUnknown()

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

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

+ func (m *ReplicationStatus) XXX_Size() int

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

+ type ReplicatorClient interface

+ Add func(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (Replicator_AddClient, error)

+ GetSubscriptionUpdate func(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*SubscriptionUpdate, error)

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

+ SubmitReplication func(ctx context.Context, in *SignedSubscription, opts ...grpc.CallOption) (Replicator_SubmitReplicationClient, error)

+ func NewReplicatorClient(cc *grpc.ClientConn) ReplicatorClient

+ type ReplicatorServer interface

+ Add func(*Subscription, Replicator_AddServer) error

+ GetSubscriptionUpdate func(context.Context, *Subscription) (*SubscriptionUpdate, error)

+ Status func(*Subscription, Replicator_StatusServer) error

+ SubmitReplication func(*SignedSubscription, Replicator_SubmitReplicationServer) error

+ type Replicator_AddClient interface

+ Recv func() (*ReplicationStatus, error)

+ type Replicator_AddServer interface

+ Send func(*ReplicationStatus) error

+ type Replicator_StatusClient interface

+ Recv func() (*ReplicationStatus, error)

+ type Replicator_StatusServer interface

+ Send func(*ReplicationStatus) error

+ type Replicator_SubmitReplicationClient interface

+ Recv func() (*ReplicationStatus, error)

+ type Replicator_SubmitReplicationServer interface

+ Send func(*ReplicationStatus) error

+ type ServerSource struct

+ AddrInfo *AddrInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewServerSourceFromHost(h HostInfo, gport int32) (*ServerSource, error)

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

+ func (*ServerSource) ProtoMessage()

+ func (m *ServerSource) GetAddrInfo() *AddrInfo

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

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

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

+ func (m *ServerSource) Reset()

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

+ func (m *ServerSource) String() string

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

+ func (m *ServerSource) XXX_DiscardUnknown()

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

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

+ func (m *ServerSource) XXX_Size() int

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

+ type SignedSubscription struct

+ SubPart *Subscription

+ UpdatePart *SubscriptionUpdate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewSignedSubscription(topic string, version int64, r *Replication, key libcryto.PrivKey) (*SignedSubscription, error)

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

+ func (*SignedSubscription) ProtoMessage()

+ func (m *SignedSubscription) GetSubPart() *Subscription

+ func (m *SignedSubscription) GetUpdatePart() *SubscriptionUpdate

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

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

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

+ func (m *SignedSubscription) Reset()

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

+ func (m *SignedSubscription) String() string

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

+ func (m *SignedSubscription) XXX_DiscardUnknown()

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

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

+ func (m *SignedSubscription) XXX_Size() int

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

+ func (ss *SignedSubscription) GetAuthorID() (peer.ID, error)

+ func (ss *SignedSubscription) GetOrCreateSubPart() *Subscription

+ func (ss *SignedSubscription) GetOrCreateUpdatePart() *SubscriptionUpdate

+ func (ss *SignedSubscription) GetReplication() (*Replication, error)

+ func (ss *SignedSubscription) GetTopic() string

+ func (ss *SignedSubscription) GetVersion() int64

+ func (ss *SignedSubscription) RemoveSignature()

+ func (ss *SignedSubscription) SetAuthorID(id peer.ID) error

+ func (ss *SignedSubscription) SetReplication(r *Replication) error

+ func (ss *SignedSubscription) SetTopic(topic string)

+ func (ss *SignedSubscription) SetVersion(v int64)

+ func (ss *SignedSubscription) Sign(key libcryto.PrivKey) error

+ func (ss *SignedSubscription) Verify(pubkey libcryto.PubKey, strict bool) error

+ type Subscription struct

+ AuthorIdBytes []byte

+ Remove bool

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Subscription) ProtoMessage()

+ func (m *Subscription) GetAuthorIdBytes() []byte

+ func (m *Subscription) GetRemove() bool

+ func (m *Subscription) GetTopic() string

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

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

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

+ func (m *Subscription) Reset()

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

+ func (m *Subscription) String() string

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

+ func (m *Subscription) XXX_DiscardUnknown()

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

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

+ func (m *Subscription) XXX_Size() int

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

+ func (s *Subscription) GetAuthorID() (peer.ID, error)

+ func (s *Subscription) SetAuthorID(id peer.ID) error

+ type SubscriptionUpdate struct

+ ReplicationBytes []byte

+ Signature []byte

+ Version int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SubscriptionUpdate) ProtoMessage()

+ func (m *SubscriptionUpdate) GetReplicationBytes() []byte

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

+ func (m *SubscriptionUpdate) GetVersion() int64

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

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

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

+ func (m *SubscriptionUpdate) Reset()

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

+ func (m *SubscriptionUpdate) String() string

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

+ func (m *SubscriptionUpdate) XXX_DiscardUnknown()

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

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

+ func (m *SubscriptionUpdate) XXX_Size() int

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

+ func (u *SubscriptionUpdate) GetReplication() (*Replication, error)

+ func (u *SubscriptionUpdate) RemoveSignature()

+ func (u *SubscriptionUpdate) SetReplication(r *Replication) error

+ type UnimplementedReplicatorServer struct

+ func (*UnimplementedReplicatorServer) Add(req *Subscription, srv Replicator_AddServer) error

+ func (*UnimplementedReplicatorServer) GetSubscriptionUpdate(ctx context.Context, req *Subscription) (*SubscriptionUpdate, error)

+ func (*UnimplementedReplicatorServer) Status(req *Subscription, srv Replicator_StatusServer) error

+ func (*UnimplementedReplicatorServer) SubmitReplication(req *SignedSubscription, srv Replicator_SubmitReplicationServer) error

v3.1.0-rc1

Feb 28, 2020

v3.0.0

Jan 2, 2020

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 CONNMGMTREQTYPE_name = map[int32]string

+ var CONNMGMTREQTYPE_value = map[string]int32

+ var DAGREQTYPE_name = map[int32]string

+ var DAGREQTYPE_value = map[string]int32

+ var EXTRASREQTYPE_name = map[int32]string

+ var EXTRASREQTYPE_value = map[string]int32

+ var EXTRASTYPE_name = map[int32]string

+ var EXTRASTYPE_value = map[string]int32

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

+ var ErrIntOverflowFile = 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 ErrInvalidLengthFile = 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 ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupFile = 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 GCREQTYPE_name = map[int32]string

+ var GCREQTYPE_value = map[string]int32

+ var KSREQTYPE_name = map[int32]string

+ var KSREQTYPE_value = map[string]int32

+ var P2PREQTYPE_name = map[int32]string

+ var P2PREQTYPE_value = map[string]int32

+ var PSREQTYPE_name = map[int32]string

+ var PSREQTYPE_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 RegisterFileAPIServer(s *grpc.Server, srv FileAPIServer)

+ 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 AdminAPIClient interface

+ 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

+ 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 (*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) String() string

+ 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

+ type Block struct

+ Cid string

+ Data []byte

+ 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) String() string

+ 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

+ type BlockstoreRequest struct

+ CidVersion string

+ Cids []string

+ Data [][]byte

+ HashFunc string

+ ReqOpts []BSREQOPTS

+ RequestType BSREQTYPE

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

+ func (*BlockstoreRequest) ProtoMessage()

+ func (m *BlockstoreRequest) GetCidVersion() string

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

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

+ func (m *BlockstoreRequest) GetHashFunc() string

+ func (m *BlockstoreRequest) GetReqOpts() []BSREQOPTS

+ func (m *BlockstoreRequest) GetRequestType() 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) String() string

+ 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

+ type BlockstoreResponse struct

+ Blocks []*Block

+ RequestType BSREQTYPE

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

+ func (*BlockstoreResponse) ProtoMessage()

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

+ func (m *BlockstoreResponse) GetRequestType() BSREQTYPE

+ 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) String() string

+ 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

+ type CONNMGMTREQTYPE int32

+ const CONNMGMTREQTYPE_CM_CONNECT

+ const CONNMGMTREQTYPE_CM_DISCONNECT

+ const CONNMGMTREQTYPE_CM_GET_PEERS

+ const CONNMGMTREQTYPE_CM_STATUS

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

+ func (x CONNMGMTREQTYPE) String() string

+ type ConnMgmtRequest struct

+ MultiAddrs []string

+ PeerIDs []string

+ RequestType CONNMGMTREQTYPE

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

+ func (*ConnMgmtRequest) ProtoMessage()

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

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

+ func (m *ConnMgmtRequest) GetRequestType() CONNMGMTREQTYPE

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

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

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

+ func (m *ConnMgmtRequest) Reset()

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

+ func (m *ConnMgmtRequest) String() string

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

+ func (m *ConnMgmtRequest) XXX_DiscardUnknown()

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

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

+ func (m *ConnMgmtRequest) XXX_Size() int

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

+ type ConnMgmtResponse struct

+ Connected map[string]bool

+ PeerIDs []string

+ RequestType CONNMGMTREQTYPE

+ Status map[string]*ConnMgmtStatus

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

+ func (*ConnMgmtResponse) ProtoMessage()

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

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

+ func (m *ConnMgmtResponse) GetRequestType() CONNMGMTREQTYPE

+ func (m *ConnMgmtResponse) GetStatus() map[string]*ConnMgmtStatus

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

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

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

+ func (m *ConnMgmtResponse) Reset()

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

+ func (m *ConnMgmtResponse) String() string

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

+ func (m *ConnMgmtResponse) XXX_DiscardUnknown()

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

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

+ func (m *ConnMgmtResponse) XXX_Size() int

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

+ type ConnMgmtStatus struct

+ Disconnected bool

+ Reason string

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

+ func (*ConnMgmtStatus) ProtoMessage()

+ func (m *ConnMgmtStatus) GetDisconnected() bool

+ func (m *ConnMgmtStatus) GetReason() string

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

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

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

+ func (m *ConnMgmtStatus) Reset()

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

+ func (m *ConnMgmtStatus) String() string

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

+ func (m *ConnMgmtStatus) XXX_DiscardUnknown()

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

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

+ func (m *ConnMgmtStatus) XXX_Size() int

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

+ type DAGREQTYPE int32

+ const DAGREQTYPE_DAG_ADD_LINKS

+ const DAGREQTYPE_DAG_GET

+ const DAGREQTYPE_DAG_GET_LINKS

+ const DAGREQTYPE_DAG_NEW_NODE

+ const DAGREQTYPE_DAG_PUT

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

+ func (x DAGREQTYPE) String() string

+ type DagRequest struct

+ CidVersion int64

+ Data []byte

+ Hash string

+ HashFunc string

+ Links map[string]string

+ ObjectEncoding string

+ RequestType DAGREQTYPE

+ SerializationFormat string

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

+ func (*DagRequest) ProtoMessage()

+ func (m *DagRequest) GetCidVersion() int64

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

+ func (m *DagRequest) GetHash() string

+ func (m *DagRequest) GetHashFunc() string

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

+ func (m *DagRequest) GetObjectEncoding() string

+ func (m *DagRequest) GetRequestType() DAGREQTYPE

+ func (m *DagRequest) GetSerializationFormat() string

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

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

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

+ func (m *DagRequest) Reset()

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

+ func (m *DagRequest) String() string

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

+ func (m *DagRequest) XXX_DiscardUnknown()

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

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

+ func (m *DagRequest) XXX_Size() int

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

+ type DagResponse struct

+ Hashes []string

+ Links []*IPLDLink

+ RawData []byte

+ RequestType DAGREQTYPE

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

+ func (*DagResponse) ProtoMessage()

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

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

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

+ func (m *DagResponse) GetRequestType() DAGREQTYPE

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

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

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

+ func (m *DagResponse) Reset()

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

+ func (m *DagResponse) String() string

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

+ func (m *DagResponse) XXX_DiscardUnknown()

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

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

+ func (m *DagResponse) XXX_Size() int

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

+ type DownloadRequest struct

+ ChunkSize int32

+ Hash string

+ 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) String() string

+ 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

+ type DownloadResponse struct

+ Blob *Blob

+ 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) String() string

+ 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

+ type EXTRASREQTYPE int32

+ const EXTRASREQTYPE_EX_DISABLE

+ const EXTRASREQTYPE_EX_ENABLE

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

+ func (x EXTRASREQTYPE) String() string

+ type EXTRASTYPE int32

+ const EXTRASTYPE_DISCOVERY

+ const EXTRASTYPE_IDENTIFY

+ const EXTRASTYPE_MDNS

+ const EXTRASTYPE_PUBSUB

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

+ func (x EXTRASTYPE) String() string

+ type Empty struct

+ 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) String() string

+ 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

+ type ExtrasRequest struct

+ ExtrasFeature EXTRASTYPE

+ RequestType EXTRASREQTYPE

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

+ func (*ExtrasRequest) ProtoMessage()

+ func (m *ExtrasRequest) GetExtrasFeature() EXTRASTYPE

+ func (m *ExtrasRequest) GetRequestType() EXTRASREQTYPE

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

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

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

+ func (m *ExtrasRequest) Reset()

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

+ func (m *ExtrasRequest) String() string

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

+ func (m *ExtrasRequest) XXX_DiscardUnknown()

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

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

+ func (m *ExtrasRequest) XXX_Size() int

+ func (m *ExtrasRequest) XXX_Unmarshal(b []byte) 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 GetPeersResponse struct

+ PeerIDs []string

+ 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) String() string

+ 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

+ type IPLDLink struct

+ Hash []byte

+ Name string

+ Size_ uint64

+ 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) String() string

+ 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

+ type IPLDNode struct

+ Data []byte

+ Links []*IPLDLink

+ 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) String() string

+ 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

+ type KSREQTYPE int32

+ const KSREQTYPE_KS_DELETE

+ const KSREQTYPE_KS_GET

+ const KSREQTYPE_KS_HAS

+ const KSREQTYPE_KS_LIST

+ const KSREQTYPE_KS_PUT

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

+ func (x KSREQTYPE) String() string

+ type KeystoreRequest struct

+ Name string

+ PrivateKey []byte

+ RequestType KSREQTYPE

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

+ func (*KeystoreRequest) ProtoMessage()

+ func (m *KeystoreRequest) GetName() string

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

+ func (m *KeystoreRequest) GetRequestType() KSREQTYPE

+ 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) String() string

+ 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

+ type KeystoreResponse struct

+ Has bool

+ KeyNames []string

+ PrivateKey []byte

+ RequestType KSREQTYPE

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

+ func (*KeystoreResponse) ProtoMessage()

+ func (m *KeystoreResponse) GetHas() bool

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

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

+ func (m *KeystoreResponse) GetRequestType() KSREQTYPE

+ 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) String() string

+ 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

+ type ManageGCRequest struct

+ Type GCREQTYPE

+ 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) String() string

+ 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

+ type ManageGCResponse struct

+ Status string

+ 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) String() string

+ 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

+ 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 (*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) String() string

+ 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

+ type NameSysResolveRequest struct

+ Depth uint32

+ DhtRecordCount uint32

+ DhtTimeout int32

+ Name string

+ 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) String() string

+ 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

+ type NameSysResolveResult struct

+ Error string

+ Path string

+ 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) String() string

+ 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

+ type NodeAPIClient interface

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

+ ConnMgmt func(ctx context.Context, in *ConnMgmtRequest, opts ...grpc.CallOption) (*ConnMgmtResponse, error)

+ Dag func(ctx context.Context, in *DagRequest, opts ...grpc.CallOption) (*DagResponse, error)

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

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

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

+ Persist func(ctx context.Context, in *PersistRequest, opts ...grpc.CallOption) (*PersistResponse, error)

+ func NewNodeAPIClient(cc *grpc.ClientConn) NodeAPIClient

+ type NodeAPIServer interface

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

+ ConnMgmt func(context.Context, *ConnMgmtRequest) (*ConnMgmtResponse, error)

+ Dag func(context.Context, *DagRequest) (*DagResponse, error)

+ Extras func(context.Context, *ExtrasRequest) (*Empty, error)

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

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

+ Persist func(context.Context, *PersistRequest) (*PersistResponse, error)

+ type P2PLsInfo struct

+ ListenAddress string

+ Local bool

+ ProtocolName string

+ TargetAddress string

+ 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) String() string

+ 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

+ 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 (*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) String() string

+ 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

+ type P2PResponse struct

+ ConnsClosed int32

+ Names []string

+ RequestType P2PREQTYPE

+ StreamInfos []*P2PLsInfo

+ 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) String() string

+ 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

+ type PSREQTYPE int32

+ const PSREQTYPE_PS_GET_TOPICS

+ const PSREQTYPE_PS_LIST_PEERS

+ const PSREQTYPE_PS_PUBLISH

+ const PSREQTYPE_PS_SUBSCRIBE

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

+ func (x PSREQTYPE) String() string

+ type PersistRequest struct

+ Cids []string

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

+ func (*PersistRequest) ProtoMessage()

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

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

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

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

+ func (m *PersistRequest) Reset()

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

+ func (m *PersistRequest) String() string

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

+ func (m *PersistRequest) XXX_DiscardUnknown()

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

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

+ func (m *PersistRequest) XXX_Size() int

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

+ type PersistResponse struct

+ Errors map[string]string

+ Status map[string]bool

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

+ func (*PersistResponse) ProtoMessage()

+ func (m *PersistResponse) GetErrors() map[string]string

+ func (m *PersistResponse) GetStatus() map[string]bool

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

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

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

+ func (m *PersistResponse) Reset()

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

+ func (m *PersistResponse) String() string

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

+ func (m *PersistResponse) XXX_DiscardUnknown()

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

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

+ func (m *PersistResponse) XXX_Size() int

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

+ type PubSubAPIClient interface

+ PubSub func(ctx context.Context, opts ...grpc.CallOption) (PubSubAPI_PubSubClient, error)

+ func NewPubSubAPIClient(cc *grpc.ClientConn) PubSubAPIClient

+ type PubSubAPIServer interface

+ PubSub func(PubSubAPI_PubSubServer) error

+ type PubSubAPI_PubSubClient interface

+ Recv func() (*PubSubResponse, error)

+ Send func(*PubSubRequest) error

+ type PubSubAPI_PubSubServer interface

+ Recv func() (*PubSubRequest, error)

+ Send func(*PubSubResponse) error

+ type PubSubMessage struct

+ Data []byte

+ From []byte

+ Key []byte

+ Seqno []byte

+ Signature []byte

+ TopicIDs []string

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

+ func (*PubSubMessage) ProtoMessage()

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

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

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

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

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

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

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

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

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

+ func (m *PubSubMessage) Reset()

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

+ func (m *PubSubMessage) String() string

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

+ func (m *PubSubMessage) XXX_DiscardUnknown()

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

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

+ func (m *PubSubMessage) XXX_Size() int

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

+ type PubSubPeer struct

+ PeerID string

+ Topic string

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

+ func (*PubSubPeer) ProtoMessage()

+ func (m *PubSubPeer) GetPeerID() string

+ func (m *PubSubPeer) GetTopic() string

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

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

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

+ func (m *PubSubPeer) Reset()

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

+ func (m *PubSubPeer) String() string

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

+ func (m *PubSubPeer) XXX_DiscardUnknown()

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

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

+ func (m *PubSubPeer) XXX_Size() int

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

+ type PubSubRequest struct

+ Data []byte

+ RequestType PSREQTYPE

+ Topics []string

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

+ func (*PubSubRequest) ProtoMessage()

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

+ func (m *PubSubRequest) GetRequestType() PSREQTYPE

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

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

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

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

+ func (m *PubSubRequest) Reset()

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

+ func (m *PubSubRequest) String() string

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

+ func (m *PubSubRequest) XXX_DiscardUnknown()

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

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

+ func (m *PubSubRequest) XXX_Size() int

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

+ type PubSubResponse struct

+ Message []*PubSubMessage

+ Peers []*PubSubPeer

+ RequestType PSREQTYPE

+ Topics []string

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

+ func (*PubSubResponse) ProtoMessage()

+ func (m *PubSubResponse) GetMessage() []*PubSubMessage

+ func (m *PubSubResponse) GetPeers() []*PubSubPeer

+ func (m *PubSubResponse) GetRequestType() PSREQTYPE

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

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

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

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

+ func (m *PubSubResponse) Reset()

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

+ func (m *PubSubResponse) String() string

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

+ func (m *PubSubResponse) XXX_DiscardUnknown()

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

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

+ func (m *PubSubResponse) XXX_Size() int

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

+ type PutResponse struct

+ Hash string

+ 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) String() string

+ 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

+ 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 (*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) String() string

+ 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

+ type RefCountResponse struct

+ Cids map[string]int64

+ 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) String() string

+ 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

+ 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 (*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) String() string

+ 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

+ type UnimplementedAdminAPIServer struct

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

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

+ type UnimplementedFileAPIServer struct

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

+ func (*UnimplementedFileAPIServer) UploadFile(srv FileAPI_UploadFileServer) 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) Blockstore(ctx context.Context, req *BlockstoreRequest) (*BlockstoreResponse, error)

+ func (*UnimplementedNodeAPIServer) ConnMgmt(ctx context.Context, req *ConnMgmtRequest) (*ConnMgmtResponse, error)

+ func (*UnimplementedNodeAPIServer) Dag(ctx context.Context, req *DagRequest) (*DagResponse, error)

+ func (*UnimplementedNodeAPIServer) Extras(ctx context.Context, req *ExtrasRequest) (*Empty, error)

+ func (*UnimplementedNodeAPIServer) Keystore(ctx context.Context, req *KeystoreRequest) (*KeystoreResponse, error)

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

+ func (*UnimplementedNodeAPIServer) Persist(ctx context.Context, req *PersistRequest) (*PersistResponse, error)

+ type UnimplementedPubSubAPIServer struct

+ func (*UnimplementedPubSubAPIServer) PubSub(srv PubSubAPI_PubSubServer) 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 (*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) String() string

+ 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

+ type UploadRequest struct

+ Blob *Blob

+ Options *UploadOptions

+ 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) String() string

+ 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

+ type VersionResponse struct

+ Version string

+ 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) String() string

+ 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

v3.0.0-rc8

Dec 30, 2019

v3.0.0-rc7

Dec 30, 2019

v3.0.0-rc6

Dec 30, 2019

v3.0.0-rc5

Dec 30, 2019

v3.0.0-rc4

Dec 30, 2019

v3.0.0-rc3

Dec 30, 2019

v3.0.0-rc2

Dec 30, 2019

v3.0.0-rc1

Dec 29, 2019

Other modules containing this package

github.com/RTradeLtd/TxPB

github.com/RTradeLtd/TxPB/v2

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