Documentation ¶
Index ¶
- Variables
- func RegisterAdminAPIServer(s *grpc.Server, srv AdminAPIServer)
- 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
- type AdminAPIClient
- type AdminAPIServer
- type BSREQOPTS
- type BSREQTYPE
- type Blob
- func (*Blob) Descriptor() ([]byte, []int)
- 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 (*Blob) ProtoMessage()
- 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
- func (*Block) Descriptor() ([]byte, []int)
- 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 (*Block) ProtoMessage()
- 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
- func (*BlockstoreRequest) Descriptor() ([]byte, []int)
- func (m *BlockstoreRequest) GetCids() []string
- func (m *BlockstoreRequest) GetData() [][]byte
- 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 (*BlockstoreRequest) ProtoMessage()
- 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
- func (*BlockstoreResponse) Descriptor() ([]byte, []int)
- 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 (*BlockstoreResponse) ProtoMessage()
- 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
- type ConnMgmtRequest
- func (*ConnMgmtRequest) Descriptor() ([]byte, []int)
- 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 (*ConnMgmtRequest) ProtoMessage()
- 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
- func (*ConnMgmtResponse) Descriptor() ([]byte, []int)
- 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 (*ConnMgmtResponse) ProtoMessage()
- 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
- func (*ConnMgmtStatus) Descriptor() ([]byte, []int)
- 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 (*ConnMgmtStatus) ProtoMessage()
- 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
- type DagRequest
- func (*DagRequest) Descriptor() ([]byte, []int)
- 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 (*DagRequest) ProtoMessage()
- 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
- func (*DagResponse) Descriptor() ([]byte, []int)
- 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 (*DagResponse) ProtoMessage()
- 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
- func (*DownloadRequest) Descriptor() ([]byte, []int)
- 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 (*DownloadRequest) ProtoMessage()
- 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
- func (*DownloadResponse) Descriptor() ([]byte, []int)
- 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 (*DownloadResponse) ProtoMessage()
- 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
- type EXTRASTYPE
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- 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 (*Empty) ProtoMessage()
- 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
- func (*ExtrasRequest) Descriptor() ([]byte, []int)
- 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 (*ExtrasRequest) ProtoMessage()
- 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
- type FileAPIServer
- type FileAPI_DownloadFileClient
- type FileAPI_DownloadFileServer
- type FileAPI_UploadFileClient
- type FileAPI_UploadFileServer
- type GCREQTYPE
- type GetPeersResponse
- func (*GetPeersResponse) Descriptor() ([]byte, []int)
- 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 (*GetPeersResponse) ProtoMessage()
- 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
- func (*IPLDLink) Descriptor() ([]byte, []int)
- 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 (*IPLDLink) ProtoMessage()
- 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
- func (*IPLDNode) Descriptor() ([]byte, []int)
- 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 (*IPLDNode) ProtoMessage()
- 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
- type KeystoreAPIClient
- type KeystoreAPIServer
- type KeystoreRequest
- func (*KeystoreRequest) Descriptor() ([]byte, []int)
- 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 (*KeystoreRequest) ProtoMessage()
- 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
- func (*KeystoreResponse) Descriptor() ([]byte, []int)
- 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 (*KeystoreResponse) ProtoMessage()
- 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
- func (*ManageGCRequest) Descriptor() ([]byte, []int)
- 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 (*ManageGCRequest) ProtoMessage()
- 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
- func (*ManageGCResponse) Descriptor() ([]byte, []int)
- 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 (*ManageGCResponse) ProtoMessage()
- 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
- type NameSysAPIServer
- type NameSysAPI_NameSysResolveAsyncClient
- type NameSysAPI_NameSysResolveAsyncServer
- type NameSysPublishRequest
- func (*NameSysPublishRequest) Descriptor() ([]byte, []int)
- 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 (*NameSysPublishRequest) ProtoMessage()
- 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
- func (*NameSysResolveRequest) Descriptor() ([]byte, []int)
- 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 (*NameSysResolveRequest) ProtoMessage()
- 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
- func (*NameSysResolveResult) Descriptor() ([]byte, []int)
- 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 (*NameSysResolveResult) ProtoMessage()
- 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
- type NodeAPIServer
- type P2PLsInfo
- func (*P2PLsInfo) Descriptor() ([]byte, []int)
- 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 (*P2PLsInfo) ProtoMessage()
- 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
- type P2PRequest
- func (*P2PRequest) Descriptor() ([]byte, []int)
- 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 (*P2PRequest) ProtoMessage()
- 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
- func (*P2PResponse) Descriptor() ([]byte, []int)
- 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 (*P2PResponse) ProtoMessage()
- 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
- type PubSubAPIClient
- type PubSubAPIServer
- type PubSubAPI_PubSubClient
- type PubSubAPI_PubSubServer
- type PubSubMessage
- func (*PubSubMessage) Descriptor() ([]byte, []int)
- 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 (*PubSubMessage) ProtoMessage()
- 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
- func (*PubSubPeer) Descriptor() ([]byte, []int)
- 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 (*PubSubPeer) ProtoMessage()
- 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
- func (*PubSubRequest) Descriptor() ([]byte, []int)
- 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 (*PubSubRequest) ProtoMessage()
- 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
- func (*PubSubResponse) Descriptor() ([]byte, []int)
- 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 (*PubSubResponse) ProtoMessage()
- 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
- func (*PutResponse) Descriptor() ([]byte, []int)
- 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 (*PutResponse) ProtoMessage()
- 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
- type REFREQTYPE
- type RefCountRequest
- func (*RefCountRequest) Descriptor() ([]byte, []int)
- 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 (*RefCountRequest) ProtoMessage()
- 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
- func (*RefCountResponse) Descriptor() ([]byte, []int)
- 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 (*RefCountResponse) ProtoMessage()
- 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
- type StatusAPIServer
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)
- 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 (*StatusResponse) ProtoMessage()
- 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
- type UnimplementedFileAPIServer
- type UnimplementedKeystoreAPIServer
- type UnimplementedNameSysAPIServer
- 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
- 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) P2P(ctx context.Context, req *P2PRequest) (*P2PResponse, error)
- type UnimplementedPubSubAPIServer
- type UnimplementedStatusAPIServer
- type UploadOptions
- func (*UploadOptions) Descriptor() ([]byte, []int)
- 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 (*UploadOptions) ProtoMessage()
- 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
- func (*UploadRequest) Descriptor() ([]byte, []int)
- 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 (*UploadRequest) ProtoMessage()
- 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
- func (*VersionResponse) Descriptor() ([]byte, []int)
- 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 (*VersionResponse) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAdmin = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthFile = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowFile = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupFile = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthKeystore = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowKeystore = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupKeystore = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthNamesys = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNamesys = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupNamesys = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNode = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupNode = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPubsub = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPubsub = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPubsub = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthStatus = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStatus = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupStatus = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthUtil = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowUtil = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupUtil = fmt.Errorf("proto: unexpected end of group") )
var APISTATUS_name = map[int32]string{
0: "ONLINE",
1: "PURGING",
2: "DEGRADED_PERFORMANCE",
3: "ERROR",
}
var APISTATUS_value = map[string]int32{
"ONLINE": 0,
"PURGING": 1,
"DEGRADED_PERFORMANCE": 2,
"ERROR": 3,
}
var BSREQOPTS_name = map[int32]string{
0: "DEFAULT",
1: "BS_FORCE",
}
var BSREQOPTS_value = map[string]int32{
"DEFAULT": 0,
"BS_FORCE": 1,
}
var BSREQTYPE_name = map[int32]string{
0: "BS_DELETE",
1: "BS_PUT",
2: "BS_PUT_MANY",
3: "BS_GET",
4: "BS_GET_MANY",
}
var BSREQTYPE_value = map[string]int32{
"BS_DELETE": 0,
"BS_PUT": 1,
"BS_PUT_MANY": 2,
"BS_GET": 3,
"BS_GET_MANY": 4,
}
var CONNMGMTREQTYPE_name = map[int32]string{
0: "CM_CONNECT",
1: "CM_DISCONNECT",
2: "CM_STATUS",
3: "CM_GET_PEERS",
}
var CONNMGMTREQTYPE_value = map[string]int32{
"CM_CONNECT": 0,
"CM_DISCONNECT": 1,
"CM_STATUS": 2,
"CM_GET_PEERS": 3,
}
var DAGREQTYPE_name = map[int32]string{
0: "DAG_PUT",
1: "DAG_GET",
2: "DAG_NEW_NODE",
3: "DAG_ADD_LINKS",
4: "DAG_GET_LINKS",
}
var DAGREQTYPE_value = map[string]int32{
"DAG_PUT": 0,
"DAG_GET": 1,
"DAG_NEW_NODE": 2,
"DAG_ADD_LINKS": 3,
"DAG_GET_LINKS": 4,
}
var EXTRASREQTYPE_name = map[int32]string{
0: "EX_ENABLE",
1: "EX_DISABLE",
}
var EXTRASREQTYPE_value = map[string]int32{
"EX_ENABLE": 0,
"EX_DISABLE": 1,
}
var EXTRASTYPE_name = map[int32]string{
0: "IDENTIFY",
1: "PUBSUB",
2: "DISCOVERY",
3: "MDNS",
}
var EXTRASTYPE_value = map[string]int32{
"IDENTIFY": 0,
"PUBSUB": 1,
"DISCOVERY": 2,
"MDNS": 3,
}
var GCREQTYPE_name = map[int32]string{
0: "GC_START",
1: "GC_STOP",
2: "GC_STATUS",
}
var GCREQTYPE_value = map[string]int32{
"GC_START": 0,
"GC_STOP": 1,
"GC_STATUS": 2,
}
var KSREQTYPE_name = map[int32]string{
0: "KS_HAS",
1: "KS_GET",
2: "KS_PUT",
3: "KS_DELETE",
4: "KS_LIST",
}
var KSREQTYPE_value = map[string]int32{
"KS_HAS": 0,
"KS_GET": 1,
"KS_PUT": 2,
"KS_DELETE": 3,
"KS_LIST": 4,
}
var P2PREQTYPE_name = map[int32]string{
0: "CLOSE",
1: "FORWARD",
2: "LISTEN",
3: "LS",
}
var P2PREQTYPE_value = map[string]int32{
"CLOSE": 0,
"FORWARD": 1,
"LISTEN": 2,
"LS": 3,
}
var PSREQTYPE_name = map[int32]string{
0: "PS_GET_TOPICS",
1: "PS_LIST_PEERS",
2: "PS_SUBSCRIBE",
3: "PS_PUBLISH",
}
var PSREQTYPE_value = map[string]int32{
"PS_GET_TOPICS": 0,
"PS_LIST_PEERS": 1,
"PS_SUBSCRIBE": 2,
"PS_PUBLISH": 3,
}
var REFREQOPTS_name = map[int32]string{
0: "REF_FORCE",
}
var REFREQOPTS_value = map[string]int32{
"REF_FORCE": 0,
}
var REFREQTYPE_name = map[int32]string{
0: "REF_GET_COUNT",
1: "REF_DELETE",
}
var REFREQTYPE_value = map[string]int32{
"REF_GET_COUNT": 0,
"REF_DELETE": 1,
}
Functions ¶
func RegisterAdminAPIServer ¶
func RegisterAdminAPIServer(s *grpc.Server, srv AdminAPIServer)
func RegisterFileAPIServer ¶
func RegisterFileAPIServer(s *grpc.Server, srv FileAPIServer)
func RegisterKeystoreAPIServer ¶
func RegisterKeystoreAPIServer(s *grpc.Server, srv KeystoreAPIServer)
func RegisterNameSysAPIServer ¶
func RegisterNameSysAPIServer(s *grpc.Server, srv NameSysAPIServer)
func RegisterNodeAPIServer ¶
func RegisterNodeAPIServer(s *grpc.Server, srv NodeAPIServer)
func RegisterPubSubAPIServer ¶
func RegisterPubSubAPIServer(s *grpc.Server, srv PubSubAPIServer)
func RegisterStatusAPIServer ¶
func RegisterStatusAPIServer(s *grpc.Server, srv StatusAPIServer)
Types ¶
type APISTATUS ¶
type APISTATUS int32
APISTATUS is an enum to return a concise description of api status
const ( // ONLINE indicates everything is working as expected APISTATUS_ONLINE APISTATUS = 0 // PURGING indicates the system is undergoing data removal // a purging system is not available for use unless all other nodes are unavailable APISTATUS_PURGING APISTATUS = 1 // DEGRADED_PERFORMANCE indicates the system is currently under heavy load APISTATUS_DEGRADED_PERFORMANCE APISTATUS = 2 // ERROR indicates that the system is currently experiencing an error and should not be used APISTATUS_ERROR APISTATUS = 3 )
func (APISTATUS) EnumDescriptor ¶
type AdminAPIClient ¶
type AdminAPIClient interface { // ManageGC is used to manage TemporalX's garbage collection process ManageGC(ctx context.Context, in *ManageGCRequest, opts ...grpc.CallOption) (*ManageGCResponse, error) // RefCount is used to analyze the counter store and pull reference count information RefCount(ctx context.Context, in *RefCountRequest, opts ...grpc.CallOption) (*RefCountResponse, error) }
AdminAPIClient is the client API for AdminAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAdminAPIClient ¶
func NewAdminAPIClient(cc *grpc.ClientConn) AdminAPIClient
type AdminAPIServer ¶
type AdminAPIServer interface { // ManageGC is used to manage TemporalX's garbage collection process ManageGC(context.Context, *ManageGCRequest) (*ManageGCResponse, error) // RefCount is used to analyze the counter store and pull reference count information RefCount(context.Context, *RefCountRequest) (*RefCountResponse, error) }
AdminAPIServer is the server API for AdminAPI service.
type BSREQOPTS ¶
type BSREQOPTS int32
BSREQOPTS are options for blockstore requests
func (BSREQOPTS) EnumDescriptor ¶
type BSREQTYPE ¶
type BSREQTYPE int32
BSREQTYPE is a particular blockstore request type
const ( // BS_DELETE is used to delete a block from the store BSREQTYPE_BS_DELETE BSREQTYPE = 0 // BS_PUT is used to put a single block in the store BSREQTYPE_BS_PUT BSREQTYPE = 1 // BS_PUT_MANY is used to put many blocks in the store BSREQTYPE_BS_PUT_MANY BSREQTYPE = 2 // BS_GET is used to get a block from the store BSREQTYPE_BS_GET BSREQTYPE = 3 // BS_GET_MANY is used to get many blocks from the store BSREQTYPE_BS_GET_MANY BSREQTYPE = 4 )
func (BSREQTYPE) EnumDescriptor ¶
type Blob ¶
type Blob struct { // content is the actual binary data contained in this message Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` }
Blob is a chunk of binary data
func (*Blob) Descriptor ¶
func (*Blob) GetContent ¶
func (*Blob) ProtoMessage ¶
func (*Blob) ProtoMessage()
func (*Blob) XXX_DiscardUnknown ¶
func (m *Blob) XXX_DiscardUnknown()
func (*Blob) XXX_Unmarshal ¶
type Block ¶
type Block struct { // cid is the identifier of the block Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"` // data is the actual contnets of this block // Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
func (*Block) Descriptor ¶
func (*Block) ProtoMessage ¶
func (*Block) ProtoMessage()
func (*Block) XXX_DiscardUnknown ¶
func (m *Block) XXX_DiscardUnknown()
func (*Block) XXX_Marshal ¶
func (*Block) XXX_Unmarshal ¶
type BlockstoreRequest ¶
type BlockstoreRequest struct { // indicates the particular request type being made RequestType BSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.BSREQTYPE" json:"requestType,omitempty"` // optional request settings ReqOpts []BSREQOPTS `protobuf:"varint,2,rep,packed,name=reqOpts,proto3,enum=pb.BSREQOPTS" json:"reqOpts,omitempty"` // cids of blocks // sent by: BS_DELETE, BS_GET, BS_GET_MANY Cids []string `protobuf:"bytes,3,rep,name=cids,proto3" json:"cids,omitempty"` // the data we are putting // sent by: BS_PUT, BS_PUT_MANY Data [][]byte `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"` }
BlockstoreRequest is a message used to control blockstores
func (*BlockstoreRequest) Descriptor ¶
func (*BlockstoreRequest) Descriptor() ([]byte, []int)
func (*BlockstoreRequest) GetCids ¶
func (m *BlockstoreRequest) GetCids() []string
func (*BlockstoreRequest) GetData ¶
func (m *BlockstoreRequest) GetData() [][]byte
func (*BlockstoreRequest) GetReqOpts ¶
func (m *BlockstoreRequest) GetReqOpts() []BSREQOPTS
func (*BlockstoreRequest) GetRequestType ¶
func (m *BlockstoreRequest) GetRequestType() BSREQTYPE
func (*BlockstoreRequest) Marshal ¶
func (m *BlockstoreRequest) Marshal() (dAtA []byte, err error)
func (*BlockstoreRequest) MarshalTo ¶
func (m *BlockstoreRequest) MarshalTo(dAtA []byte) (int, error)
func (*BlockstoreRequest) MarshalToSizedBuffer ¶
func (m *BlockstoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BlockstoreRequest) ProtoMessage ¶
func (*BlockstoreRequest) ProtoMessage()
func (*BlockstoreRequest) Reset ¶
func (m *BlockstoreRequest) Reset()
func (*BlockstoreRequest) Size ¶
func (m *BlockstoreRequest) Size() (n int)
func (*BlockstoreRequest) String ¶
func (m *BlockstoreRequest) String() string
func (*BlockstoreRequest) Unmarshal ¶
func (m *BlockstoreRequest) Unmarshal(dAtA []byte) error
func (*BlockstoreRequest) XXX_DiscardUnknown ¶
func (m *BlockstoreRequest) XXX_DiscardUnknown()
func (*BlockstoreRequest) XXX_Marshal ¶
func (m *BlockstoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BlockstoreRequest) XXX_Merge ¶
func (m *BlockstoreRequest) XXX_Merge(src proto.Message)
func (*BlockstoreRequest) XXX_Size ¶
func (m *BlockstoreRequest) XXX_Size() int
func (*BlockstoreRequest) XXX_Unmarshal ¶
func (m *BlockstoreRequest) XXX_Unmarshal(b []byte) error
type BlockstoreResponse ¶
type BlockstoreResponse struct { // indicates the particular request type being made RequestType BSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.BSREQTYPE" json:"requestType,omitempty"` // a copy of blocks from the blockstore // sent by: BS_PUT, BS_PUT_MANY, BS_GET, BS_GET_MANY // in the case of BS_PUT, and BS_PUT_MANY requests // the data field will be empty as this is only populated // by get requests Blocks []*Block `protobuf:"bytes,2,rep,name=blocks,proto3" json:"blocks,omitempty"` }
BlockstoreResponse is a response to a BlockstoreqRequest
func (*BlockstoreResponse) Descriptor ¶
func (*BlockstoreResponse) Descriptor() ([]byte, []int)
func (*BlockstoreResponse) GetBlocks ¶
func (m *BlockstoreResponse) GetBlocks() []*Block
func (*BlockstoreResponse) GetRequestType ¶
func (m *BlockstoreResponse) GetRequestType() BSREQTYPE
func (*BlockstoreResponse) Marshal ¶
func (m *BlockstoreResponse) Marshal() (dAtA []byte, err error)
func (*BlockstoreResponse) MarshalTo ¶
func (m *BlockstoreResponse) MarshalTo(dAtA []byte) (int, error)
func (*BlockstoreResponse) MarshalToSizedBuffer ¶
func (m *BlockstoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BlockstoreResponse) ProtoMessage ¶
func (*BlockstoreResponse) ProtoMessage()
func (*BlockstoreResponse) Reset ¶
func (m *BlockstoreResponse) Reset()
func (*BlockstoreResponse) Size ¶
func (m *BlockstoreResponse) Size() (n int)
func (*BlockstoreResponse) String ¶
func (m *BlockstoreResponse) String() string
func (*BlockstoreResponse) Unmarshal ¶
func (m *BlockstoreResponse) Unmarshal(dAtA []byte) error
func (*BlockstoreResponse) XXX_DiscardUnknown ¶
func (m *BlockstoreResponse) XXX_DiscardUnknown()
func (*BlockstoreResponse) XXX_Marshal ¶
func (m *BlockstoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BlockstoreResponse) XXX_Merge ¶
func (m *BlockstoreResponse) XXX_Merge(src proto.Message)
func (*BlockstoreResponse) XXX_Size ¶
func (m *BlockstoreResponse) XXX_Size() int
func (*BlockstoreResponse) XXX_Unmarshal ¶
func (m *BlockstoreResponse) XXX_Unmarshal(b []byte) error
type CONNMGMTREQTYPE ¶
type CONNMGMTREQTYPE int32
CONNMGMTREQTYPE indicates the particular ConnMgmt request being performed
const ( // CM_CONNECT is used to connect to a libp2p peer CONNMGMTREQTYPE_CM_CONNECT CONNMGMTREQTYPE = 0 // CM_DISCONNECT is used to disconnect from a libp2p peer CONNMGMTREQTYPE_CM_DISCONNECT CONNMGMTREQTYPE = 1 // CM_STATUS is used to return status information about libp2p peer connections // useful for determining whether or not we are connected to someone CONNMGMTREQTYPE_CM_STATUS CONNMGMTREQTYPE = 2 //CM_GET_PEERS is used to return all known peers CONNMGMTREQTYPE_CM_GET_PEERS CONNMGMTREQTYPE = 3 )
func (CONNMGMTREQTYPE) EnumDescriptor ¶
func (CONNMGMTREQTYPE) EnumDescriptor() ([]byte, []int)
func (CONNMGMTREQTYPE) String ¶
func (x CONNMGMTREQTYPE) String() string
type ConnMgmtRequest ¶
type ConnMgmtRequest struct { // indicates the particular connection management request being performed RequestType CONNMGMTREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.CONNMGMTREQTYPE" json:"requestType,omitempty"` // a list of multiaddrs // sent by: CM_CONNECT MultiAddrs []string `protobuf:"bytes,2,rep,name=multiAddrs,proto3" json:"multiAddrs,omitempty"` // a list of peer IDs // sent by: CM_DISCONNECT, CM_STATUS, CM_GET_PEERS PeerIDs []string `protobuf:"bytes,3,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"` }
func (*ConnMgmtRequest) Descriptor ¶
func (*ConnMgmtRequest) Descriptor() ([]byte, []int)
func (*ConnMgmtRequest) GetMultiAddrs ¶
func (m *ConnMgmtRequest) GetMultiAddrs() []string
func (*ConnMgmtRequest) GetPeerIDs ¶
func (m *ConnMgmtRequest) GetPeerIDs() []string
func (*ConnMgmtRequest) GetRequestType ¶
func (m *ConnMgmtRequest) GetRequestType() CONNMGMTREQTYPE
func (*ConnMgmtRequest) Marshal ¶
func (m *ConnMgmtRequest) Marshal() (dAtA []byte, err error)
func (*ConnMgmtRequest) MarshalToSizedBuffer ¶
func (m *ConnMgmtRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnMgmtRequest) ProtoMessage ¶
func (*ConnMgmtRequest) ProtoMessage()
func (*ConnMgmtRequest) Reset ¶
func (m *ConnMgmtRequest) Reset()
func (*ConnMgmtRequest) Size ¶
func (m *ConnMgmtRequest) Size() (n int)
func (*ConnMgmtRequest) String ¶
func (m *ConnMgmtRequest) String() string
func (*ConnMgmtRequest) Unmarshal ¶
func (m *ConnMgmtRequest) Unmarshal(dAtA []byte) error
func (*ConnMgmtRequest) XXX_DiscardUnknown ¶
func (m *ConnMgmtRequest) XXX_DiscardUnknown()
func (*ConnMgmtRequest) XXX_Marshal ¶
func (m *ConnMgmtRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnMgmtRequest) XXX_Merge ¶
func (m *ConnMgmtRequest) XXX_Merge(src proto.Message)
func (*ConnMgmtRequest) XXX_Size ¶
func (m *ConnMgmtRequest) XXX_Size() int
func (*ConnMgmtRequest) XXX_Unmarshal ¶
func (m *ConnMgmtRequest) XXX_Unmarshal(b []byte) error
type ConnMgmtResponse ¶
type ConnMgmtResponse struct { // indicates the particular connection management request being performed RequestType CONNMGMTREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.CONNMGMTREQTYPE" json:"requestType,omitempty"` Connected map[string]bool `` /* 160-byte string literal not displayed */ // a map of the peer id, and a custom message indicating success, or why there was a failure Status map[string]*ConnMgmtStatus `` /* 153-byte string literal not displayed */ PeerIDs []string `protobuf:"bytes,4,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"` }
func (*ConnMgmtResponse) Descriptor ¶
func (*ConnMgmtResponse) Descriptor() ([]byte, []int)
func (*ConnMgmtResponse) GetConnected ¶
func (m *ConnMgmtResponse) GetConnected() map[string]bool
func (*ConnMgmtResponse) GetPeerIDs ¶
func (m *ConnMgmtResponse) GetPeerIDs() []string
func (*ConnMgmtResponse) GetRequestType ¶
func (m *ConnMgmtResponse) GetRequestType() CONNMGMTREQTYPE
func (*ConnMgmtResponse) GetStatus ¶
func (m *ConnMgmtResponse) GetStatus() map[string]*ConnMgmtStatus
func (*ConnMgmtResponse) Marshal ¶
func (m *ConnMgmtResponse) Marshal() (dAtA []byte, err error)
func (*ConnMgmtResponse) MarshalToSizedBuffer ¶
func (m *ConnMgmtResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnMgmtResponse) ProtoMessage ¶
func (*ConnMgmtResponse) ProtoMessage()
func (*ConnMgmtResponse) Reset ¶
func (m *ConnMgmtResponse) Reset()
func (*ConnMgmtResponse) Size ¶
func (m *ConnMgmtResponse) Size() (n int)
func (*ConnMgmtResponse) String ¶
func (m *ConnMgmtResponse) String() string
func (*ConnMgmtResponse) Unmarshal ¶
func (m *ConnMgmtResponse) Unmarshal(dAtA []byte) error
func (*ConnMgmtResponse) XXX_DiscardUnknown ¶
func (m *ConnMgmtResponse) XXX_DiscardUnknown()
func (*ConnMgmtResponse) XXX_Marshal ¶
func (m *ConnMgmtResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnMgmtResponse) XXX_Merge ¶
func (m *ConnMgmtResponse) XXX_Merge(src proto.Message)
func (*ConnMgmtResponse) XXX_Size ¶
func (m *ConnMgmtResponse) XXX_Size() int
func (*ConnMgmtResponse) XXX_Unmarshal ¶
func (m *ConnMgmtResponse) XXX_Unmarshal(b []byte) error
type ConnMgmtStatus ¶
type ConnMgmtStatus struct { // indicate whether or not we actually disconnected Disconnected bool `protobuf:"varint,1,opt,name=disconnected,proto3" json:"disconnected,omitempty"` // if disconnected is false, the reason why it is false Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` }
Contains status information about a particular disconnect attempt
func (*ConnMgmtStatus) Descriptor ¶
func (*ConnMgmtStatus) Descriptor() ([]byte, []int)
func (*ConnMgmtStatus) GetDisconnected ¶
func (m *ConnMgmtStatus) GetDisconnected() bool
func (*ConnMgmtStatus) GetReason ¶
func (m *ConnMgmtStatus) GetReason() string
func (*ConnMgmtStatus) Marshal ¶
func (m *ConnMgmtStatus) Marshal() (dAtA []byte, err error)
func (*ConnMgmtStatus) MarshalToSizedBuffer ¶
func (m *ConnMgmtStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnMgmtStatus) ProtoMessage ¶
func (*ConnMgmtStatus) ProtoMessage()
func (*ConnMgmtStatus) Reset ¶
func (m *ConnMgmtStatus) Reset()
func (*ConnMgmtStatus) Size ¶
func (m *ConnMgmtStatus) Size() (n int)
func (*ConnMgmtStatus) String ¶
func (m *ConnMgmtStatus) String() string
func (*ConnMgmtStatus) Unmarshal ¶
func (m *ConnMgmtStatus) Unmarshal(dAtA []byte) error
func (*ConnMgmtStatus) XXX_DiscardUnknown ¶
func (m *ConnMgmtStatus) XXX_DiscardUnknown()
func (*ConnMgmtStatus) XXX_Marshal ¶
func (m *ConnMgmtStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnMgmtStatus) XXX_Merge ¶
func (m *ConnMgmtStatus) XXX_Merge(src proto.Message)
func (*ConnMgmtStatus) XXX_Size ¶
func (m *ConnMgmtStatus) XXX_Size() int
func (*ConnMgmtStatus) XXX_Unmarshal ¶
func (m *ConnMgmtStatus) XXX_Unmarshal(b []byte) error
type DAGREQTYPE ¶
type DAGREQTYPE int32
DAGREQTYPE indicates the particular DagAPI request being performed
const ( // DAG_PUT is used to add new IPLD objects DAGREQTYPE_DAG_PUT DAGREQTYPE = 0 // DAG_GET is used to retrieve IPLD object data DAGREQTYPE_DAG_GET DAGREQTYPE = 1 // DAG_NEW_NODE is used to create a new IPLD node object DAGREQTYPE_DAG_NEW_NODE DAGREQTYPE = 2 // DAG_ADD_LINKS is used to add links to an IPLD node object DAGREQTYPE_DAG_ADD_LINKS DAGREQTYPE = 3 // DAG_GET_LINKS is used to retrieve all links contained in an IPLD node object DAGREQTYPE_DAG_GET_LINKS DAGREQTYPE = 4 )
func (DAGREQTYPE) EnumDescriptor ¶
func (DAGREQTYPE) EnumDescriptor() ([]byte, []int)
func (DAGREQTYPE) String ¶
func (x DAGREQTYPE) String() string
type DagRequest ¶
type DagRequest struct { // indicates the request being performed // sent by: all request types RequestType DAGREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.DAGREQTYPE" json:"requestType,omitempty"` // data that we will be storing // sent by: DAG_PUT, DAG_NEW_NODE Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // the object encoding type (raw, cbor, protobuf, etc...) // sent by: DAG_PUT ObjectEncoding string `protobuf:"bytes,3,opt,name=objectEncoding,proto3" json:"objectEncoding,omitempty"` // the serialization format (raw, cbor, protobuf, etc...) // sent by: DAG_PUT SerializationFormat string `protobuf:"bytes,4,opt,name=serializationFormat,proto3" json:"serializationFormat,omitempty"` // the hash function to to use (sha2-256, sha3-512, etc...) // sent by: DAG_PUT, DAG_NEW_NODE, DAG_ADD_LINKS HashFunc string `protobuf:"bytes,5,opt,name=hashFunc,proto3" json:"hashFunc,omitempty"` // the cid version to use (0, 1) // sent by: DAG_PUT, DAG_NEW_NODE CidVersion int64 `protobuf:"varint,6,opt,name=cidVersion,proto3" json:"cidVersion,omitempty"` // the hash of the object we are processing // sent by: DAG_GET, DAG_NEW_NODe, DAG_ADD_LINKS, DAG_GET_LINKS Hash string `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"` // indicates links and their names. key = name, value = link hash // sent by: DAG_NEW_NODE, DAG_ADD_LINKS Links map[string]string `` /* 151-byte string literal not displayed */ }
Used to submit a request to Dag or DagStream RPCs
func (*DagRequest) Descriptor ¶
func (*DagRequest) Descriptor() ([]byte, []int)
func (*DagRequest) GetCidVersion ¶
func (m *DagRequest) GetCidVersion() int64
func (*DagRequest) GetData ¶
func (m *DagRequest) GetData() []byte
func (*DagRequest) GetHash ¶
func (m *DagRequest) GetHash() string
func (*DagRequest) GetHashFunc ¶
func (m *DagRequest) GetHashFunc() string
func (*DagRequest) GetLinks ¶
func (m *DagRequest) GetLinks() map[string]string
func (*DagRequest) GetObjectEncoding ¶
func (m *DagRequest) GetObjectEncoding() string
func (*DagRequest) GetRequestType ¶
func (m *DagRequest) GetRequestType() DAGREQTYPE
func (*DagRequest) GetSerializationFormat ¶
func (m *DagRequest) GetSerializationFormat() string
func (*DagRequest) Marshal ¶
func (m *DagRequest) Marshal() (dAtA []byte, err error)
func (*DagRequest) MarshalToSizedBuffer ¶
func (m *DagRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DagRequest) ProtoMessage ¶
func (*DagRequest) ProtoMessage()
func (*DagRequest) Reset ¶
func (m *DagRequest) Reset()
func (*DagRequest) Size ¶
func (m *DagRequest) Size() (n int)
func (*DagRequest) String ¶
func (m *DagRequest) String() string
func (*DagRequest) Unmarshal ¶
func (m *DagRequest) Unmarshal(dAtA []byte) error
func (*DagRequest) XXX_DiscardUnknown ¶
func (m *DagRequest) XXX_DiscardUnknown()
func (*DagRequest) XXX_Marshal ¶
func (m *DagRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DagRequest) XXX_Merge ¶
func (m *DagRequest) XXX_Merge(src proto.Message)
func (*DagRequest) XXX_Size ¶
func (m *DagRequest) XXX_Size() int
func (*DagRequest) XXX_Unmarshal ¶
func (m *DagRequest) XXX_Unmarshal(b []byte) error
type DagResponse ¶
type DagResponse struct { // indicates the request being performed // sent by: all request types RequestType DAGREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.DAGREQTYPE" json:"requestType,omitempty"` // returns the hashes of newly generated IPLD objects // sent by: DAG_PUT, DAG_NEW_NODE, DAG_ADD_LINKS, DAG_GET_LINKS Hashes []string `protobuf:"bytes,2,rep,name=hashes,proto3" json:"hashes,omitempty"` // the actual data contained by the IPLD object // sent by: DAG_GET RawData []byte `protobuf:"bytes,3,opt,name=rawData,proto3" json:"rawData,omitempty"` // the links contained within an IPLD node object // sent by: DAG_GET_LINKS Links []*IPLDLink `protobuf:"bytes,4,rep,name=links,proto3" json:"links,omitempty"` }
Used in response to a Dag or DagStream RPC
func (*DagResponse) Descriptor ¶
func (*DagResponse) Descriptor() ([]byte, []int)
func (*DagResponse) GetHashes ¶
func (m *DagResponse) GetHashes() []string
func (*DagResponse) GetLinks ¶
func (m *DagResponse) GetLinks() []*IPLDLink
func (*DagResponse) GetRawData ¶
func (m *DagResponse) GetRawData() []byte
func (*DagResponse) GetRequestType ¶
func (m *DagResponse) GetRequestType() DAGREQTYPE
func (*DagResponse) Marshal ¶
func (m *DagResponse) Marshal() (dAtA []byte, err error)
func (*DagResponse) MarshalToSizedBuffer ¶
func (m *DagResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DagResponse) ProtoMessage ¶
func (*DagResponse) ProtoMessage()
func (*DagResponse) Reset ¶
func (m *DagResponse) Reset()
func (*DagResponse) Size ¶
func (m *DagResponse) Size() (n int)
func (*DagResponse) String ¶
func (m *DagResponse) String() string
func (*DagResponse) Unmarshal ¶
func (m *DagResponse) Unmarshal(dAtA []byte) error
func (*DagResponse) XXX_DiscardUnknown ¶
func (m *DagResponse) XXX_DiscardUnknown()
func (*DagResponse) XXX_Marshal ¶
func (m *DagResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DagResponse) XXX_Merge ¶
func (m *DagResponse) XXX_Merge(src proto.Message)
func (*DagResponse) XXX_Size ¶
func (m *DagResponse) XXX_Size() int
func (*DagResponse) XXX_Unmarshal ¶
func (m *DagResponse) XXX_Unmarshal(b []byte) error
type DownloadRequest ¶
type DownloadRequest struct { // hash is the ipfs hash/cid (content identifier) of the data to download Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // chunkSize specifies the size of chunks to be sent to the client // it allows us to efficiently control incoming data amounts which // is useful on machines with low-memory ChunkSize int32 `protobuf:"varint,2,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"` }
DownloadRequest is used to download a UnixFS object although it can in theory be used with other type of objects there may be some undefined behavior
func (*DownloadRequest) Descriptor ¶
func (*DownloadRequest) Descriptor() ([]byte, []int)
func (*DownloadRequest) GetChunkSize ¶
func (m *DownloadRequest) GetChunkSize() int32
func (*DownloadRequest) GetHash ¶
func (m *DownloadRequest) GetHash() string
func (*DownloadRequest) Marshal ¶
func (m *DownloadRequest) Marshal() (dAtA []byte, err error)
func (*DownloadRequest) MarshalToSizedBuffer ¶
func (m *DownloadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DownloadRequest) ProtoMessage ¶
func (*DownloadRequest) ProtoMessage()
func (*DownloadRequest) Reset ¶
func (m *DownloadRequest) Reset()
func (*DownloadRequest) Size ¶
func (m *DownloadRequest) Size() (n int)
func (*DownloadRequest) String ¶
func (m *DownloadRequest) String() string
func (*DownloadRequest) Unmarshal ¶
func (m *DownloadRequest) Unmarshal(dAtA []byte) error
func (*DownloadRequest) XXX_DiscardUnknown ¶
func (m *DownloadRequest) XXX_DiscardUnknown()
func (*DownloadRequest) XXX_Marshal ¶
func (m *DownloadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DownloadRequest) XXX_Merge ¶
func (m *DownloadRequest) XXX_Merge(src proto.Message)
func (*DownloadRequest) XXX_Size ¶
func (m *DownloadRequest) XXX_Size() int
func (*DownloadRequest) XXX_Unmarshal ¶
func (m *DownloadRequest) XXX_Unmarshal(b []byte) error
type DownloadResponse ¶
type DownloadResponse struct { // blob is a single chunk of data Blob *Blob `protobuf:"bytes,1,opt,name=blob,proto3" json:"blob,omitempty"` }
DownloadResponse contains the response to a download request which allows the gRPC server to stream blobs to the client
func (*DownloadResponse) Descriptor ¶
func (*DownloadResponse) Descriptor() ([]byte, []int)
func (*DownloadResponse) GetBlob ¶
func (m *DownloadResponse) GetBlob() *Blob
func (*DownloadResponse) Marshal ¶
func (m *DownloadResponse) Marshal() (dAtA []byte, err error)
func (*DownloadResponse) MarshalToSizedBuffer ¶
func (m *DownloadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DownloadResponse) ProtoMessage ¶
func (*DownloadResponse) ProtoMessage()
func (*DownloadResponse) Reset ¶
func (m *DownloadResponse) Reset()
func (*DownloadResponse) Size ¶
func (m *DownloadResponse) Size() (n int)
func (*DownloadResponse) String ¶
func (m *DownloadResponse) String() string
func (*DownloadResponse) Unmarshal ¶
func (m *DownloadResponse) Unmarshal(dAtA []byte) error
func (*DownloadResponse) XXX_DiscardUnknown ¶
func (m *DownloadResponse) XXX_DiscardUnknown()
func (*DownloadResponse) XXX_Marshal ¶
func (m *DownloadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DownloadResponse) XXX_Merge ¶
func (m *DownloadResponse) XXX_Merge(src proto.Message)
func (*DownloadResponse) XXX_Size ¶
func (m *DownloadResponse) XXX_Size() int
func (*DownloadResponse) XXX_Unmarshal ¶
func (m *DownloadResponse) XXX_Unmarshal(b []byte) error
type EXTRASREQTYPE ¶
type EXTRASREQTYPE int32
EXTRASREQTYPE indicates the particular Extras request being performed
const ( // EX_ENABLE is used to enable a particular node extras feature EXTRASREQTYPE_EX_ENABLE EXTRASREQTYPE = 0 // EX_DISABLE is used to disable a particular node extras feature EXTRASREQTYPE_EX_DISABLE EXTRASREQTYPE = 1 )
func (EXTRASREQTYPE) EnumDescriptor ¶
func (EXTRASREQTYPE) EnumDescriptor() ([]byte, []int)
func (EXTRASREQTYPE) String ¶
func (x EXTRASREQTYPE) String() string
type EXTRASTYPE ¶
type EXTRASTYPE int32
EXTRASTYPE denotes a particular extras type
const ( // IDENTIFY is the identify service EXTRASTYPE_IDENTIFY EXTRASTYPE = 0 // PUBSUB is the libp2p pubsub system EXTRASTYPE_PUBSUB EXTRASTYPE = 1 // DISCOVERY is a libp2p discovery service EXTRASTYPE_DISCOVERY EXTRASTYPE = 2 // MDNS is used to discover libp2p hosts over mdns EXTRASTYPE_MDNS EXTRASTYPE = 3 )
func (EXTRASTYPE) EnumDescriptor ¶
func (EXTRASTYPE) EnumDescriptor() ([]byte, []int)
func (EXTRASTYPE) String ¶
func (x EXTRASTYPE) String() string
type Empty ¶
type Empty struct { }
Empty is an empty message
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type ExtrasRequest ¶
type ExtrasRequest struct { // indicates the request being performed RequestType EXTRASREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.EXTRASREQTYPE" json:"requestType,omitempty"` // indicates the extras feature this request applies to ExtrasFeature EXTRASTYPE `protobuf:"varint,2,opt,name=extrasFeature,proto3,enum=pb.EXTRASTYPE" json:"extrasFeature,omitempty"` }
func (*ExtrasRequest) Descriptor ¶
func (*ExtrasRequest) Descriptor() ([]byte, []int)
func (*ExtrasRequest) GetExtrasFeature ¶
func (m *ExtrasRequest) GetExtrasFeature() EXTRASTYPE
func (*ExtrasRequest) GetRequestType ¶
func (m *ExtrasRequest) GetRequestType() EXTRASREQTYPE
func (*ExtrasRequest) Marshal ¶
func (m *ExtrasRequest) Marshal() (dAtA []byte, err error)
func (*ExtrasRequest) MarshalToSizedBuffer ¶
func (m *ExtrasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExtrasRequest) ProtoMessage ¶
func (*ExtrasRequest) ProtoMessage()
func (*ExtrasRequest) Reset ¶
func (m *ExtrasRequest) Reset()
func (*ExtrasRequest) Size ¶
func (m *ExtrasRequest) Size() (n int)
func (*ExtrasRequest) String ¶
func (m *ExtrasRequest) String() string
func (*ExtrasRequest) Unmarshal ¶
func (m *ExtrasRequest) Unmarshal(dAtA []byte) error
func (*ExtrasRequest) XXX_DiscardUnknown ¶
func (m *ExtrasRequest) XXX_DiscardUnknown()
func (*ExtrasRequest) XXX_Marshal ¶
func (m *ExtrasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtrasRequest) XXX_Merge ¶
func (m *ExtrasRequest) XXX_Merge(src proto.Message)
func (*ExtrasRequest) XXX_Size ¶
func (m *ExtrasRequest) XXX_Size() int
func (*ExtrasRequest) XXX_Unmarshal ¶
func (m *ExtrasRequest) XXX_Unmarshal(b []byte) error
type FileAPIClient ¶
type FileAPIClient interface { // UploadFile allows uploading a file as a UnixFS object (equivalent to ipfs add) UploadFile(ctx context.Context, opts ...grpc.CallOption) (FileAPI_UploadFileClient, error) // DownloadFile allows downloading a UnixFS object (equivalent to ipfs get) DownloadFile(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (FileAPI_DownloadFileClient, error) }
FileAPIClient is the client API for FileAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewFileAPIClient ¶
func NewFileAPIClient(cc *grpc.ClientConn) FileAPIClient
type FileAPIServer ¶
type FileAPIServer interface { // UploadFile allows uploading a file as a UnixFS object (equivalent to ipfs add) UploadFile(FileAPI_UploadFileServer) error // DownloadFile allows downloading a UnixFS object (equivalent to ipfs get) DownloadFile(*DownloadRequest, FileAPI_DownloadFileServer) error }
FileAPIServer is the server API for FileAPI service.
type FileAPI_DownloadFileClient ¶
type FileAPI_DownloadFileClient interface { Recv() (*DownloadResponse, error) grpc.ClientStream }
type FileAPI_DownloadFileServer ¶
type FileAPI_DownloadFileServer interface { Send(*DownloadResponse) error grpc.ServerStream }
type FileAPI_UploadFileClient ¶
type FileAPI_UploadFileClient interface { Send(*UploadRequest) error CloseAndRecv() (*PutResponse, error) grpc.ClientStream }
type FileAPI_UploadFileServer ¶
type FileAPI_UploadFileServer interface { SendAndClose(*PutResponse) error Recv() (*UploadRequest, error) grpc.ServerStream }
type GCREQTYPE ¶
type GCREQTYPE int32
GCREQTYPE specifies the type of GC management call being performed
func (GCREQTYPE) EnumDescriptor ¶
type GetPeersResponse ¶
type GetPeersResponse struct { // a slice of peer IDs PeerIDs []string `protobuf:"bytes,1,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"` }
GetPeersResponse is a response to GetPeers containing a slice of peer IDs
func (*GetPeersResponse) Descriptor ¶
func (*GetPeersResponse) Descriptor() ([]byte, []int)
func (*GetPeersResponse) GetPeerIDs ¶
func (m *GetPeersResponse) GetPeerIDs() []string
func (*GetPeersResponse) Marshal ¶
func (m *GetPeersResponse) Marshal() (dAtA []byte, err error)
func (*GetPeersResponse) MarshalToSizedBuffer ¶
func (m *GetPeersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetPeersResponse) ProtoMessage ¶
func (*GetPeersResponse) ProtoMessage()
func (*GetPeersResponse) Reset ¶
func (m *GetPeersResponse) Reset()
func (*GetPeersResponse) Size ¶
func (m *GetPeersResponse) Size() (n int)
func (*GetPeersResponse) String ¶
func (m *GetPeersResponse) String() string
func (*GetPeersResponse) Unmarshal ¶
func (m *GetPeersResponse) Unmarshal(dAtA []byte) error
func (*GetPeersResponse) XXX_DiscardUnknown ¶
func (m *GetPeersResponse) XXX_DiscardUnknown()
func (*GetPeersResponse) XXX_Marshal ¶
func (m *GetPeersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPeersResponse) XXX_Merge ¶
func (m *GetPeersResponse) XXX_Merge(src proto.Message)
func (*GetPeersResponse) XXX_Size ¶
func (m *GetPeersResponse) XXX_Size() int
func (*GetPeersResponse) XXX_Unmarshal ¶
func (m *GetPeersResponse) XXX_Unmarshal(b []byte) error
type IPLDLink ¶
type IPLDLink struct { // multihash of the target object Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // utf string name. should be unique per object Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // cumulative size of target object Size_ uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` }
An IPFS MerkleDAG Link
func (*IPLDLink) Descriptor ¶
func (*IPLDLink) MarshalToSizedBuffer ¶
func (*IPLDLink) ProtoMessage ¶
func (*IPLDLink) ProtoMessage()
func (*IPLDLink) XXX_DiscardUnknown ¶
func (m *IPLDLink) XXX_DiscardUnknown()
func (*IPLDLink) XXX_Marshal ¶
func (*IPLDLink) XXX_Unmarshal ¶
type IPLDNode ¶
type IPLDNode struct { // refs to other objects Links []*IPLDLink `protobuf:"bytes,2,rep,name=links,proto3" json:"links,omitempty"` // opaque user data Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` }
An IPFS MerkleDAG Node
func (*IPLDNode) Descriptor ¶
func (*IPLDNode) MarshalToSizedBuffer ¶
func (*IPLDNode) ProtoMessage ¶
func (*IPLDNode) ProtoMessage()
func (*IPLDNode) XXX_DiscardUnknown ¶
func (m *IPLDNode) XXX_DiscardUnknown()
func (*IPLDNode) XXX_Marshal ¶
func (*IPLDNode) XXX_Unmarshal ¶
type KSREQTYPE ¶
type KSREQTYPE int32
KSREQTYPE indicates the particular KeystoreAPI request being performed
const ( // KS_HAS is used to check if the key exists in our keystore KSREQTYPE_KS_HAS KSREQTYPE = 0 // KS_GET is used to retrieve private key bytes from our keystore KSREQTYPE_KS_GET KSREQTYPE = 1 // KS_PUT is used to store private key bytes in our keystore KSREQTYPE_KS_PUT KSREQTYPE = 2 // KS_DELETE is used to delete private keys from our keystore KSREQTYPE_KS_DELETE KSREQTYPE = 3 // KS_LIST is used to list all keys in our keystore by their name KSREQTYPE_KS_LIST KSREQTYPE = 4 )
func (KSREQTYPE) EnumDescriptor ¶
type KeystoreAPIClient ¶
type KeystoreAPIClient interface { //Keystore is a unidirectional RPC allowing management of ipfs keystores Keystore(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error) }
KeystoreAPIClient is the client API for KeystoreAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewKeystoreAPIClient ¶
func NewKeystoreAPIClient(cc *grpc.ClientConn) KeystoreAPIClient
type KeystoreAPIServer ¶
type KeystoreAPIServer interface { //Keystore is a unidirectional RPC allowing management of ipfs keystores Keystore(context.Context, *KeystoreRequest) (*KeystoreResponse, error) }
KeystoreAPIServer is the server API for KeystoreAPI service.
type KeystoreRequest ¶
type KeystoreRequest struct { // indicates the request type being performed RequestType KSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.KSREQTYPE" json:"requestType,omitempty"` // name of the key the request is for // sent by: KS_HAS, KS_GET, KS_PUT, KS_DELETE Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // the actual private key bytes // sent by: KS_PUT PrivateKey []byte `protobuf:"bytes,3,opt,name=privateKey,proto3" json:"privateKey,omitempty"` }
Used to submit a request to Keystore RPC
func (*KeystoreRequest) Descriptor ¶
func (*KeystoreRequest) Descriptor() ([]byte, []int)
func (*KeystoreRequest) GetName ¶
func (m *KeystoreRequest) GetName() string
func (*KeystoreRequest) GetPrivateKey ¶
func (m *KeystoreRequest) GetPrivateKey() []byte
func (*KeystoreRequest) GetRequestType ¶
func (m *KeystoreRequest) GetRequestType() KSREQTYPE
func (*KeystoreRequest) Marshal ¶
func (m *KeystoreRequest) Marshal() (dAtA []byte, err error)
func (*KeystoreRequest) MarshalToSizedBuffer ¶
func (m *KeystoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeystoreRequest) ProtoMessage ¶
func (*KeystoreRequest) ProtoMessage()
func (*KeystoreRequest) Reset ¶
func (m *KeystoreRequest) Reset()
func (*KeystoreRequest) Size ¶
func (m *KeystoreRequest) Size() (n int)
func (*KeystoreRequest) String ¶
func (m *KeystoreRequest) String() string
func (*KeystoreRequest) Unmarshal ¶
func (m *KeystoreRequest) Unmarshal(dAtA []byte) error
func (*KeystoreRequest) XXX_DiscardUnknown ¶
func (m *KeystoreRequest) XXX_DiscardUnknown()
func (*KeystoreRequest) XXX_Marshal ¶
func (m *KeystoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeystoreRequest) XXX_Merge ¶
func (m *KeystoreRequest) XXX_Merge(src proto.Message)
func (*KeystoreRequest) XXX_Size ¶
func (m *KeystoreRequest) XXX_Size() int
func (*KeystoreRequest) XXX_Unmarshal ¶
func (m *KeystoreRequest) XXX_Unmarshal(b []byte) error
type KeystoreResponse ¶
type KeystoreResponse struct { // indicates the request type being performed RequestType KSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.KSREQTYPE" json:"requestType,omitempty"` // the private key bytes // sent by: KS_GET PrivateKey []byte `protobuf:"bytes,2,opt,name=privateKey,proto3" json:"privateKey,omitempty"` // contains all known key names // sent by: KS_LIST KeyNames []string `protobuf:"bytes,3,rep,name=keyNames,proto3" json:"keyNames,omitempty"` // indicates if we have the key in our keystore // sent by: KS_HAS Has bool `protobuf:"varint,4,opt,name=has,proto3" json:"has,omitempty"` }
Used in response to a Keystore RPC
func (*KeystoreResponse) Descriptor ¶
func (*KeystoreResponse) Descriptor() ([]byte, []int)
func (*KeystoreResponse) GetHas ¶
func (m *KeystoreResponse) GetHas() bool
func (*KeystoreResponse) GetKeyNames ¶
func (m *KeystoreResponse) GetKeyNames() []string
func (*KeystoreResponse) GetPrivateKey ¶
func (m *KeystoreResponse) GetPrivateKey() []byte
func (*KeystoreResponse) GetRequestType ¶
func (m *KeystoreResponse) GetRequestType() KSREQTYPE
func (*KeystoreResponse) Marshal ¶
func (m *KeystoreResponse) Marshal() (dAtA []byte, err error)
func (*KeystoreResponse) MarshalToSizedBuffer ¶
func (m *KeystoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeystoreResponse) ProtoMessage ¶
func (*KeystoreResponse) ProtoMessage()
func (*KeystoreResponse) Reset ¶
func (m *KeystoreResponse) Reset()
func (*KeystoreResponse) Size ¶
func (m *KeystoreResponse) Size() (n int)
func (*KeystoreResponse) String ¶
func (m *KeystoreResponse) String() string
func (*KeystoreResponse) Unmarshal ¶
func (m *KeystoreResponse) Unmarshal(dAtA []byte) error
func (*KeystoreResponse) XXX_DiscardUnknown ¶
func (m *KeystoreResponse) XXX_DiscardUnknown()
func (*KeystoreResponse) XXX_Marshal ¶
func (m *KeystoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeystoreResponse) XXX_Merge ¶
func (m *KeystoreResponse) XXX_Merge(src proto.Message)
func (*KeystoreResponse) XXX_Size ¶
func (m *KeystoreResponse) XXX_Size() int
func (*KeystoreResponse) XXX_Unmarshal ¶
func (m *KeystoreResponse) XXX_Unmarshal(b []byte) error
type ManageGCRequest ¶
type ManageGCRequest struct { // type is the type of gc request being performed Type GCREQTYPE `protobuf:"varint,1,opt,name=type,proto3,enum=pb.GCREQTYPE" json:"type,omitempty"` }
ManageGCRequest is a message used to control TemporalX garbage collection
func (*ManageGCRequest) Descriptor ¶
func (*ManageGCRequest) Descriptor() ([]byte, []int)
func (*ManageGCRequest) GetType ¶
func (m *ManageGCRequest) GetType() GCREQTYPE
func (*ManageGCRequest) Marshal ¶
func (m *ManageGCRequest) Marshal() (dAtA []byte, err error)
func (*ManageGCRequest) MarshalToSizedBuffer ¶
func (m *ManageGCRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ManageGCRequest) ProtoMessage ¶
func (*ManageGCRequest) ProtoMessage()
func (*ManageGCRequest) Reset ¶
func (m *ManageGCRequest) Reset()
func (*ManageGCRequest) Size ¶
func (m *ManageGCRequest) Size() (n int)
func (*ManageGCRequest) String ¶
func (m *ManageGCRequest) String() string
func (*ManageGCRequest) Unmarshal ¶
func (m *ManageGCRequest) Unmarshal(dAtA []byte) error
func (*ManageGCRequest) XXX_DiscardUnknown ¶
func (m *ManageGCRequest) XXX_DiscardUnknown()
func (*ManageGCRequest) XXX_Marshal ¶
func (m *ManageGCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ManageGCRequest) XXX_Merge ¶
func (m *ManageGCRequest) XXX_Merge(src proto.Message)
func (*ManageGCRequest) XXX_Size ¶
func (m *ManageGCRequest) XXX_Size() int
func (*ManageGCRequest) XXX_Unmarshal ¶
func (m *ManageGCRequest) XXX_Unmarshal(b []byte) error
type ManageGCResponse ¶
type ManageGCResponse struct { // status contains a status message Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` }
ManageGCResponse is a message used as a response to gc control requests
func (*ManageGCResponse) Descriptor ¶
func (*ManageGCResponse) Descriptor() ([]byte, []int)
func (*ManageGCResponse) GetStatus ¶
func (m *ManageGCResponse) GetStatus() string
func (*ManageGCResponse) Marshal ¶
func (m *ManageGCResponse) Marshal() (dAtA []byte, err error)
func (*ManageGCResponse) MarshalToSizedBuffer ¶
func (m *ManageGCResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ManageGCResponse) ProtoMessage ¶
func (*ManageGCResponse) ProtoMessage()
func (*ManageGCResponse) Reset ¶
func (m *ManageGCResponse) Reset()
func (*ManageGCResponse) Size ¶
func (m *ManageGCResponse) Size() (n int)
func (*ManageGCResponse) String ¶
func (m *ManageGCResponse) String() string
func (*ManageGCResponse) Unmarshal ¶
func (m *ManageGCResponse) Unmarshal(dAtA []byte) error
func (*ManageGCResponse) XXX_DiscardUnknown ¶
func (m *ManageGCResponse) XXX_DiscardUnknown()
func (*ManageGCResponse) XXX_Marshal ¶
func (m *ManageGCResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ManageGCResponse) XXX_Merge ¶
func (m *ManageGCResponse) XXX_Merge(src proto.Message)
func (*ManageGCResponse) XXX_Size ¶
func (m *ManageGCResponse) XXX_Size() int
func (*ManageGCResponse) XXX_Unmarshal ¶
func (m *ManageGCResponse) XXX_Unmarshal(b []byte) error
type NameSysAPIClient ¶
type NameSysAPIClient interface { // NameSysResolve is used to resolve a name, waiting for the request to complete NameSysResolve(ctx context.Context, in *NameSysResolveRequest, opts ...grpc.CallOption) (*NameSysResolveResult, error) // NameSysResolveAsync is like Resolve, except instead of waiting for the request // to complete, we send back a stream which we will send the result on NameSysResolveAsync(ctx context.Context, in *NameSysResolveRequest, opts ...grpc.CallOption) (NameSysAPI_NameSysResolveAsyncClient, error) // NameSysPublish is used to publish an IPNS record, with/with-out an EOL NameSysPublish(ctx context.Context, in *NameSysPublishRequest, opts ...grpc.CallOption) (*Empty, error) }
NameSysAPIClient is the client API for NameSysAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNameSysAPIClient ¶
func NewNameSysAPIClient(cc *grpc.ClientConn) NameSysAPIClient
type NameSysAPIServer ¶
type NameSysAPIServer interface { // NameSysResolve is used to resolve a name, waiting for the request to complete NameSysResolve(context.Context, *NameSysResolveRequest) (*NameSysResolveResult, error) // NameSysResolveAsync is like Resolve, except instead of waiting for the request // to complete, we send back a stream which we will send the result on NameSysResolveAsync(*NameSysResolveRequest, NameSysAPI_NameSysResolveAsyncServer) error // NameSysPublish is used to publish an IPNS record, with/with-out an EOL NameSysPublish(context.Context, *NameSysPublishRequest) (*Empty, error) }
NameSysAPIServer is the server API for NameSysAPI service.
type NameSysAPI_NameSysResolveAsyncClient ¶
type NameSysAPI_NameSysResolveAsyncClient interface { Recv() (*NameSysResolveResult, error) grpc.ClientStream }
type NameSysAPI_NameSysResolveAsyncServer ¶
type NameSysAPI_NameSysResolveAsyncServer interface { Send(*NameSysResolveResult) error grpc.ServerStream }
type NameSysPublishRequest ¶
type NameSysPublishRequest struct { // the private key (name) for this record PrivateKey []byte `protobuf:"bytes,1,opt,name=privateKey,proto3" json:"privateKey,omitempty"` // the value of this record Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // the eol for this publish, if 0 implies // as NameSys::Publish call, if non 0 implies // a NameSys:PublishWithEOL call Eol int32 `protobuf:"varint,3,opt,name=eol,proto3" json:"eol,omitempty"` // if set, allows us to override default // ttl value of ipns records Ttl int32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"` }
NameSysPublishRequest is used to publish a value
func (*NameSysPublishRequest) Descriptor ¶
func (*NameSysPublishRequest) Descriptor() ([]byte, []int)
func (*NameSysPublishRequest) GetEol ¶
func (m *NameSysPublishRequest) GetEol() int32
func (*NameSysPublishRequest) GetPrivateKey ¶
func (m *NameSysPublishRequest) GetPrivateKey() []byte
func (*NameSysPublishRequest) GetTtl ¶
func (m *NameSysPublishRequest) GetTtl() int32
func (*NameSysPublishRequest) GetValue ¶
func (m *NameSysPublishRequest) GetValue() string
func (*NameSysPublishRequest) Marshal ¶
func (m *NameSysPublishRequest) Marshal() (dAtA []byte, err error)
func (*NameSysPublishRequest) MarshalTo ¶
func (m *NameSysPublishRequest) MarshalTo(dAtA []byte) (int, error)
func (*NameSysPublishRequest) MarshalToSizedBuffer ¶
func (m *NameSysPublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NameSysPublishRequest) ProtoMessage ¶
func (*NameSysPublishRequest) ProtoMessage()
func (*NameSysPublishRequest) Reset ¶
func (m *NameSysPublishRequest) Reset()
func (*NameSysPublishRequest) Size ¶
func (m *NameSysPublishRequest) Size() (n int)
func (*NameSysPublishRequest) String ¶
func (m *NameSysPublishRequest) String() string
func (*NameSysPublishRequest) Unmarshal ¶
func (m *NameSysPublishRequest) Unmarshal(dAtA []byte) error
func (*NameSysPublishRequest) XXX_DiscardUnknown ¶
func (m *NameSysPublishRequest) XXX_DiscardUnknown()
func (*NameSysPublishRequest) XXX_Marshal ¶
func (m *NameSysPublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NameSysPublishRequest) XXX_Merge ¶
func (m *NameSysPublishRequest) XXX_Merge(src proto.Message)
func (*NameSysPublishRequest) XXX_Size ¶
func (m *NameSysPublishRequest) XXX_Size() int
func (*NameSysPublishRequest) XXX_Unmarshal ¶
func (m *NameSysPublishRequest) XXX_Unmarshal(b []byte) error
type NameSysResolveRequest ¶
type NameSysResolveRequest struct { // the name to resolve Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // recursion depth limit Depth uint32 `protobuf:"varint,2,opt,name=depth,proto3" json:"depth,omitempty"` // number of ipns records to retrieve // before selecting the best record DhtRecordCount uint32 `protobuf:"varint,3,opt,name=dhtRecordCount,proto3" json:"dhtRecordCount,omitempty"` // the amount of time to wait // for records to be fetched and verified DhtTimeout int32 `protobuf:"varint,4,opt,name=dhtTimeout,proto3" json:"dhtTimeout,omitempty"` }
NameSysResolveRequest is used to resolve an IPNS name
func (*NameSysResolveRequest) Descriptor ¶
func (*NameSysResolveRequest) Descriptor() ([]byte, []int)
func (*NameSysResolveRequest) GetDepth ¶
func (m *NameSysResolveRequest) GetDepth() uint32
func (*NameSysResolveRequest) GetDhtRecordCount ¶
func (m *NameSysResolveRequest) GetDhtRecordCount() uint32
func (*NameSysResolveRequest) GetDhtTimeout ¶
func (m *NameSysResolveRequest) GetDhtTimeout() int32
func (*NameSysResolveRequest) GetName ¶
func (m *NameSysResolveRequest) GetName() string
func (*NameSysResolveRequest) Marshal ¶
func (m *NameSysResolveRequest) Marshal() (dAtA []byte, err error)
func (*NameSysResolveRequest) MarshalTo ¶
func (m *NameSysResolveRequest) MarshalTo(dAtA []byte) (int, error)
func (*NameSysResolveRequest) MarshalToSizedBuffer ¶
func (m *NameSysResolveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NameSysResolveRequest) ProtoMessage ¶
func (*NameSysResolveRequest) ProtoMessage()
func (*NameSysResolveRequest) Reset ¶
func (m *NameSysResolveRequest) Reset()
func (*NameSysResolveRequest) Size ¶
func (m *NameSysResolveRequest) Size() (n int)
func (*NameSysResolveRequest) String ¶
func (m *NameSysResolveRequest) String() string
func (*NameSysResolveRequest) Unmarshal ¶
func (m *NameSysResolveRequest) Unmarshal(dAtA []byte) error
func (*NameSysResolveRequest) XXX_DiscardUnknown ¶
func (m *NameSysResolveRequest) XXX_DiscardUnknown()
func (*NameSysResolveRequest) XXX_Marshal ¶
func (m *NameSysResolveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NameSysResolveRequest) XXX_Merge ¶
func (m *NameSysResolveRequest) XXX_Merge(src proto.Message)
func (*NameSysResolveRequest) XXX_Size ¶
func (m *NameSysResolveRequest) XXX_Size() int
func (*NameSysResolveRequest) XXX_Unmarshal ¶
func (m *NameSysResolveRequest) XXX_Unmarshal(b []byte) error
type NameSysResolveResult ¶
type NameSysResolveResult struct { // the path that was resolved Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // an error if any Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
NameSysResolveRequest is an answer to a resolve request
func (*NameSysResolveResult) Descriptor ¶
func (*NameSysResolveResult) Descriptor() ([]byte, []int)
func (*NameSysResolveResult) GetError ¶
func (m *NameSysResolveResult) GetError() string
func (*NameSysResolveResult) GetPath ¶
func (m *NameSysResolveResult) GetPath() string
func (*NameSysResolveResult) Marshal ¶
func (m *NameSysResolveResult) Marshal() (dAtA []byte, err error)
func (*NameSysResolveResult) MarshalTo ¶
func (m *NameSysResolveResult) MarshalTo(dAtA []byte) (int, error)
func (*NameSysResolveResult) MarshalToSizedBuffer ¶
func (m *NameSysResolveResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NameSysResolveResult) ProtoMessage ¶
func (*NameSysResolveResult) ProtoMessage()
func (*NameSysResolveResult) Reset ¶
func (m *NameSysResolveResult) Reset()
func (*NameSysResolveResult) Size ¶
func (m *NameSysResolveResult) Size() (n int)
func (*NameSysResolveResult) String ¶
func (m *NameSysResolveResult) String() string
func (*NameSysResolveResult) Unmarshal ¶
func (m *NameSysResolveResult) Unmarshal(dAtA []byte) error
func (*NameSysResolveResult) XXX_DiscardUnknown ¶
func (m *NameSysResolveResult) XXX_DiscardUnknown()
func (*NameSysResolveResult) XXX_Marshal ¶
func (m *NameSysResolveResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NameSysResolveResult) XXX_Merge ¶
func (m *NameSysResolveResult) XXX_Merge(src proto.Message)
func (*NameSysResolveResult) XXX_Size ¶
func (m *NameSysResolveResult) XXX_Size() int
func (*NameSysResolveResult) XXX_Unmarshal ¶
func (m *NameSysResolveResult) XXX_Unmarshal(b []byte) error
type NodeAPIClient ¶
type NodeAPIClient interface { // ConnMgmt provides control over libp2p connections ConnMgmt(ctx context.Context, in *ConnMgmtRequest, opts ...grpc.CallOption) (*ConnMgmtResponse, error) // Extras provide control over node extras capabilities Extras(ctx context.Context, in *ExtrasRequest, opts ...grpc.CallOption) (*Empty, error) // P2P allows control of generalized p2p streams for tcp/udp based protocol. // By using this RPC, we can tunnel traffic similar to ssh tunneling // except using libp2p as the transport layer, and and tcp/udp port. P2P(ctx context.Context, in *P2PRequest, opts ...grpc.CallOption) (*P2PResponse, error) // Blockstore allows low-level management of the underlying blockstore Blockstore(ctx context.Context, in *BlockstoreRequest, opts ...grpc.CallOption) (*BlockstoreResponse, error) // Dag is a unidirectional rpc allowing manipulation of low-level ipld objects Dag(ctx context.Context, in *DagRequest, opts ...grpc.CallOption) (*DagResponse, error) }
NodeAPIClient is the client API for NodeAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNodeAPIClient ¶
func NewNodeAPIClient(cc *grpc.ClientConn) NodeAPIClient
type NodeAPIServer ¶
type NodeAPIServer interface { // ConnMgmt provides control over libp2p connections ConnMgmt(context.Context, *ConnMgmtRequest) (*ConnMgmtResponse, error) // Extras provide control over node extras capabilities Extras(context.Context, *ExtrasRequest) (*Empty, error) // P2P allows control of generalized p2p streams for tcp/udp based protocol. // By using this RPC, we can tunnel traffic similar to ssh tunneling // except using libp2p as the transport layer, and and tcp/udp port. P2P(context.Context, *P2PRequest) (*P2PResponse, error) // Blockstore allows low-level management of the underlying blockstore Blockstore(context.Context, *BlockstoreRequest) (*BlockstoreResponse, error) // Dag is a unidirectional rpc allowing manipulation of low-level ipld objects Dag(context.Context, *DagRequest) (*DagResponse, error) }
NodeAPIServer is the server API for NodeAPI service.
type P2PLsInfo ¶
type P2PLsInfo struct { ProtocolName string `protobuf:"bytes,1,opt,name=protocolName,proto3" json:"protocolName,omitempty"` ListenAddress string `protobuf:"bytes,2,opt,name=listenAddress,proto3" json:"listenAddress,omitempty"` TargetAddress string `protobuf:"bytes,3,opt,name=targetAddress,proto3" json:"targetAddress,omitempty"` // indicates whether or not this is a p2p listener or local listener Local bool `protobuf:"varint,4,opt,name=local,proto3" json:"local,omitempty"` }
P2PLsInfo contains information about a single p2p stream
func (*P2PLsInfo) Descriptor ¶
func (*P2PLsInfo) GetListenAddress ¶
func (*P2PLsInfo) GetProtocolName ¶
func (*P2PLsInfo) GetTargetAddress ¶
func (*P2PLsInfo) MarshalToSizedBuffer ¶
func (*P2PLsInfo) ProtoMessage ¶
func (*P2PLsInfo) ProtoMessage()
func (*P2PLsInfo) XXX_DiscardUnknown ¶
func (m *P2PLsInfo) XXX_DiscardUnknown()
func (*P2PLsInfo) XXX_Marshal ¶
func (*P2PLsInfo) XXX_Unmarshal ¶
type P2PREQTYPE ¶
type P2PREQTYPE int32
P2PREQTYPE denotes the particular type of request being used in the p2p rpc
const ( // equivalent of ipfs p2p close P2PREQTYPE_CLOSE P2PREQTYPE = 0 // equivalent of ipfs p2p forward P2PREQTYPE_FORWARD P2PREQTYPE = 1 // equivalent of ipfs p2p listen P2PREQTYPE_LISTEN P2PREQTYPE = 2 // equivalent of ipfs p2p ls P2PREQTYPE_LS P2PREQTYPE = 3 )
func (P2PREQTYPE) EnumDescriptor ¶
func (P2PREQTYPE) EnumDescriptor() ([]byte, []int)
func (P2PREQTYPE) String ¶
func (x P2PREQTYPE) String() string
type P2PRequest ¶
type P2PRequest struct { // indicates the request type RequestType P2PREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.P2PREQTYPE" json:"requestType,omitempty"` // used by: P2PREQTYPE.CLOSE All bool `protobuf:"varint,2,opt,name=all,proto3" json:"all,omitempty"` // used by: P2PREQTYPE.LS Verbose bool `protobuf:"varint,3,opt,name=verbose,proto3" json:"verbose,omitempty"` // used by: P2PREQTYPE.CLOSE, P2PREQTYPE.FORWARD, P2PREQTYPE.LISTEN ProtocolName string `protobuf:"bytes,4,opt,name=protocolName,proto3" json:"protocolName,omitempty"` // used by: P2PREQTYPE.CLOSE, P2PREQTYPE.FORWARD // must be specified as a multiaddr ListenAddress string `protobuf:"bytes,5,opt,name=listenAddress,proto3" json:"listenAddress,omitempty"` // used by: P2PREQTYPE.CLOSE, P2PREQTYPE.FORWARD // must be specified as a multiaddr TargetAddress string `protobuf:"bytes,6,opt,name=targetAddress,proto3" json:"targetAddress,omitempty"` // used by: P2PREQTYPE.LISTEN // must be specified as a multiaddr RemoteAddress string `protobuf:"bytes,7,opt,name=remoteAddress,proto3" json:"remoteAddress,omitempty"` // used by: P2PREQTYPE.LISTEN, P2PREQTYPE.FORWARD AllowCustomProtocols bool `protobuf:"varint,8,opt,name=allowCustomProtocols,proto3" json:"allowCustomProtocols,omitempty"` // used by: P2PREQTYPE.LISTEN ReportPeerID bool `protobuf:"varint,9,opt,name=reportPeerID,proto3" json:"reportPeerID,omitempty"` }
P2PRequest is a request message holding the details of a particular P2P rpc call
func (*P2PRequest) Descriptor ¶
func (*P2PRequest) Descriptor() ([]byte, []int)
func (*P2PRequest) GetAll ¶
func (m *P2PRequest) GetAll() bool
func (*P2PRequest) GetAllowCustomProtocols ¶
func (m *P2PRequest) GetAllowCustomProtocols() bool
func (*P2PRequest) GetListenAddress ¶
func (m *P2PRequest) GetListenAddress() string
func (*P2PRequest) GetProtocolName ¶
func (m *P2PRequest) GetProtocolName() string
func (*P2PRequest) GetRemoteAddress ¶
func (m *P2PRequest) GetRemoteAddress() string
func (*P2PRequest) GetReportPeerID ¶
func (m *P2PRequest) GetReportPeerID() bool
func (*P2PRequest) GetRequestType ¶
func (m *P2PRequest) GetRequestType() P2PREQTYPE
func (*P2PRequest) GetTargetAddress ¶
func (m *P2PRequest) GetTargetAddress() string
func (*P2PRequest) GetVerbose ¶
func (m *P2PRequest) GetVerbose() bool
func (*P2PRequest) Marshal ¶
func (m *P2PRequest) Marshal() (dAtA []byte, err error)
func (*P2PRequest) MarshalToSizedBuffer ¶
func (m *P2PRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*P2PRequest) ProtoMessage ¶
func (*P2PRequest) ProtoMessage()
func (*P2PRequest) Reset ¶
func (m *P2PRequest) Reset()
func (*P2PRequest) Size ¶
func (m *P2PRequest) Size() (n int)
func (*P2PRequest) String ¶
func (m *P2PRequest) String() string
func (*P2PRequest) Unmarshal ¶
func (m *P2PRequest) Unmarshal(dAtA []byte) error
func (*P2PRequest) XXX_DiscardUnknown ¶
func (m *P2PRequest) XXX_DiscardUnknown()
func (*P2PRequest) XXX_Marshal ¶
func (m *P2PRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*P2PRequest) XXX_Merge ¶
func (m *P2PRequest) XXX_Merge(src proto.Message)
func (*P2PRequest) XXX_Size ¶
func (m *P2PRequest) XXX_Size() int
func (*P2PRequest) XXX_Unmarshal ¶
func (m *P2PRequest) XXX_Unmarshal(b []byte) error
type P2PResponse ¶
type P2PResponse struct { RequestType P2PREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.P2PREQTYPE" json:"requestType,omitempty"` // sent by: P2PREQTYPE.LISTEN Names []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"` // sent by: P2PREQTYPE.CLOSE to indicate the number of connections closed ConnsClosed int32 `protobuf:"varint,3,opt,name=connsClosed,proto3" json:"connsClosed,omitempty"` // sent by: P2PREQTYPE.LS and contains all known stream information StreamInfos []*P2PLsInfo `protobuf:"bytes,4,rep,name=streamInfos,proto3" json:"streamInfos,omitempty"` }
P2PResponse is a response message sent in response to a P2PRequest message
func (*P2PResponse) Descriptor ¶
func (*P2PResponse) Descriptor() ([]byte, []int)
func (*P2PResponse) GetConnsClosed ¶
func (m *P2PResponse) GetConnsClosed() int32
func (*P2PResponse) GetNames ¶
func (m *P2PResponse) GetNames() []string
func (*P2PResponse) GetRequestType ¶
func (m *P2PResponse) GetRequestType() P2PREQTYPE
func (*P2PResponse) GetStreamInfos ¶
func (m *P2PResponse) GetStreamInfos() []*P2PLsInfo
func (*P2PResponse) Marshal ¶
func (m *P2PResponse) Marshal() (dAtA []byte, err error)
func (*P2PResponse) MarshalToSizedBuffer ¶
func (m *P2PResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*P2PResponse) ProtoMessage ¶
func (*P2PResponse) ProtoMessage()
func (*P2PResponse) Reset ¶
func (m *P2PResponse) Reset()
func (*P2PResponse) Size ¶
func (m *P2PResponse) Size() (n int)
func (*P2PResponse) String ¶
func (m *P2PResponse) String() string
func (*P2PResponse) Unmarshal ¶
func (m *P2PResponse) Unmarshal(dAtA []byte) error
func (*P2PResponse) XXX_DiscardUnknown ¶
func (m *P2PResponse) XXX_DiscardUnknown()
func (*P2PResponse) XXX_Marshal ¶
func (m *P2PResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*P2PResponse) XXX_Merge ¶
func (m *P2PResponse) XXX_Merge(src proto.Message)
func (*P2PResponse) XXX_Size ¶
func (m *P2PResponse) XXX_Size() int
func (*P2PResponse) XXX_Unmarshal ¶
func (m *P2PResponse) XXX_Unmarshal(b []byte) error
type PSREQTYPE ¶
type PSREQTYPE int32
PSREQTYPE indicates the particular PubSubAPI request being performed
const ( // PS_GET_TOPICS is used to return a list of subscribed pubsub topics PSREQTYPE_PS_GET_TOPICS PSREQTYPE = 0 // PS_LIST_PEERS is used to return a list of peers subscribed to topics we are subscribed to PSREQTYPE_PS_LIST_PEERS PSREQTYPE = 1 // PS_SUBSCRIBE is used to establish a persistent subscription to a pubsub topic PSREQTYPE_PS_SUBSCRIBE PSREQTYPE = 2 // PS_PUBLISH is used to publisbh a message to a pubsub topic PSREQTYPE_PS_PUBLISH PSREQTYPE = 3 )
func (PSREQTYPE) EnumDescriptor ¶
type PubSubAPIClient ¶
type PubSubAPIClient interface { // PubSub allows controlling libp2p pubsub topics and subscriptions using // a bidirectional streaming API PubSub(ctx context.Context, opts ...grpc.CallOption) (PubSubAPI_PubSubClient, error) }
PubSubAPIClient is the client API for PubSubAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPubSubAPIClient ¶
func NewPubSubAPIClient(cc *grpc.ClientConn) PubSubAPIClient
type PubSubAPIServer ¶
type PubSubAPIServer interface { // PubSub allows controlling libp2p pubsub topics and subscriptions using // a bidirectional streaming API PubSub(PubSubAPI_PubSubServer) error }
PubSubAPIServer is the server API for PubSubAPI service.
type PubSubAPI_PubSubClient ¶
type PubSubAPI_PubSubClient interface { Send(*PubSubRequest) error Recv() (*PubSubResponse, error) grpc.ClientStream }
type PubSubAPI_PubSubServer ¶
type PubSubAPI_PubSubServer interface { Send(*PubSubResponse) error Recv() (*PubSubRequest, error) grpc.ServerStream }
type PubSubMessage ¶
type PubSubMessage struct { // who this message is from From []byte `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` // the data of this message Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // the sequence number of this message Seqno []byte `protobuf:"bytes,3,opt,name=seqno,proto3" json:"seqno,omitempty"` // the topic IDs this message is sent to TopicIDs []string `protobuf:"bytes,4,rep,name=topicIDs,proto3" json:"topicIDs,omitempty"` // the signature of the sender Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"` // the key of the sender Key []byte `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"` }
func (*PubSubMessage) Descriptor ¶
func (*PubSubMessage) Descriptor() ([]byte, []int)
func (*PubSubMessage) GetData ¶
func (m *PubSubMessage) GetData() []byte
func (*PubSubMessage) GetFrom ¶
func (m *PubSubMessage) GetFrom() []byte
func (*PubSubMessage) GetKey ¶
func (m *PubSubMessage) GetKey() []byte
func (*PubSubMessage) GetSeqno ¶
func (m *PubSubMessage) GetSeqno() []byte
func (*PubSubMessage) GetSignature ¶
func (m *PubSubMessage) GetSignature() []byte
func (*PubSubMessage) GetTopicIDs ¶
func (m *PubSubMessage) GetTopicIDs() []string
func (*PubSubMessage) Marshal ¶
func (m *PubSubMessage) Marshal() (dAtA []byte, err error)
func (*PubSubMessage) MarshalToSizedBuffer ¶
func (m *PubSubMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PubSubMessage) ProtoMessage ¶
func (*PubSubMessage) ProtoMessage()
func (*PubSubMessage) Reset ¶
func (m *PubSubMessage) Reset()
func (*PubSubMessage) Size ¶
func (m *PubSubMessage) Size() (n int)
func (*PubSubMessage) String ¶
func (m *PubSubMessage) String() string
func (*PubSubMessage) Unmarshal ¶
func (m *PubSubMessage) Unmarshal(dAtA []byte) error
func (*PubSubMessage) XXX_DiscardUnknown ¶
func (m *PubSubMessage) XXX_DiscardUnknown()
func (*PubSubMessage) XXX_Marshal ¶
func (m *PubSubMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PubSubMessage) XXX_Merge ¶
func (m *PubSubMessage) XXX_Merge(src proto.Message)
func (*PubSubMessage) XXX_Size ¶
func (m *PubSubMessage) XXX_Size() int
func (*PubSubMessage) XXX_Unmarshal ¶
func (m *PubSubMessage) XXX_Unmarshal(b []byte) error
type PubSubPeer ¶
type PubSubPeer struct { // the topic this peer belongs to Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // the id of this peer PeerID string `protobuf:"bytes,2,opt,name=peerID,proto3" json:"peerID,omitempty"` }
represents an individual pubsub peer
func (*PubSubPeer) Descriptor ¶
func (*PubSubPeer) Descriptor() ([]byte, []int)
func (*PubSubPeer) GetPeerID ¶
func (m *PubSubPeer) GetPeerID() string
func (*PubSubPeer) GetTopic ¶
func (m *PubSubPeer) GetTopic() string
func (*PubSubPeer) Marshal ¶
func (m *PubSubPeer) Marshal() (dAtA []byte, err error)
func (*PubSubPeer) MarshalToSizedBuffer ¶
func (m *PubSubPeer) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PubSubPeer) ProtoMessage ¶
func (*PubSubPeer) ProtoMessage()
func (*PubSubPeer) Reset ¶
func (m *PubSubPeer) Reset()
func (*PubSubPeer) Size ¶
func (m *PubSubPeer) Size() (n int)
func (*PubSubPeer) String ¶
func (m *PubSubPeer) String() string
func (*PubSubPeer) Unmarshal ¶
func (m *PubSubPeer) Unmarshal(dAtA []byte) error
func (*PubSubPeer) XXX_DiscardUnknown ¶
func (m *PubSubPeer) XXX_DiscardUnknown()
func (*PubSubPeer) XXX_Marshal ¶
func (m *PubSubPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PubSubPeer) XXX_Merge ¶
func (m *PubSubPeer) XXX_Merge(src proto.Message)
func (*PubSubPeer) XXX_Size ¶
func (m *PubSubPeer) XXX_Size() int
func (*PubSubPeer) XXX_Unmarshal ¶
func (m *PubSubPeer) XXX_Unmarshal(b []byte) error
type PubSubRequest ¶
type PubSubRequest struct { // indicates the particular PubSubAPI request being performed RequestType PSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.PSREQTYPE" json:"requestType,omitempty"` // topics to request peers from, or publish data to // sent by: PS_LIST_PEERS, PS_SUBSCRIBE, PS_PUBLISH Topics []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"` // data to sent to topics // sent by: PS_PUBLISH Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` }
func (*PubSubRequest) Descriptor ¶
func (*PubSubRequest) Descriptor() ([]byte, []int)
func (*PubSubRequest) GetData ¶
func (m *PubSubRequest) GetData() []byte
func (*PubSubRequest) GetRequestType ¶
func (m *PubSubRequest) GetRequestType() PSREQTYPE
func (*PubSubRequest) GetTopics ¶
func (m *PubSubRequest) GetTopics() []string
func (*PubSubRequest) Marshal ¶
func (m *PubSubRequest) Marshal() (dAtA []byte, err error)
func (*PubSubRequest) MarshalToSizedBuffer ¶
func (m *PubSubRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PubSubRequest) ProtoMessage ¶
func (*PubSubRequest) ProtoMessage()
func (*PubSubRequest) Reset ¶
func (m *PubSubRequest) Reset()
func (*PubSubRequest) Size ¶
func (m *PubSubRequest) Size() (n int)
func (*PubSubRequest) String ¶
func (m *PubSubRequest) String() string
func (*PubSubRequest) Unmarshal ¶
func (m *PubSubRequest) Unmarshal(dAtA []byte) error
func (*PubSubRequest) XXX_DiscardUnknown ¶
func (m *PubSubRequest) XXX_DiscardUnknown()
func (*PubSubRequest) XXX_Marshal ¶
func (m *PubSubRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PubSubRequest) XXX_Merge ¶
func (m *PubSubRequest) XXX_Merge(src proto.Message)
func (*PubSubRequest) XXX_Size ¶
func (m *PubSubRequest) XXX_Size() int
func (*PubSubRequest) XXX_Unmarshal ¶
func (m *PubSubRequest) XXX_Unmarshal(b []byte) error
type PubSubResponse ¶
type PubSubResponse struct { // indicates the particular PubSubAPI request being performed RequestType PSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.PSREQTYPE" json:"requestType,omitempty"` // messages we have received from a topic // sent by: PS_SUBSCRIBE Message []*PubSubMessage `protobuf:"bytes,2,rep,name=message,proto3" json:"message,omitempty"` // topic names // sent by: PS_GET_TOPICS Topics []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"` // pubsub peers // sent by: PS_LIST_PEERS Peers []*PubSubPeer `protobuf:"bytes,4,rep,name=peers,proto3" json:"peers,omitempty"` }
func (*PubSubResponse) Descriptor ¶
func (*PubSubResponse) Descriptor() ([]byte, []int)
func (*PubSubResponse) GetMessage ¶
func (m *PubSubResponse) GetMessage() []*PubSubMessage
func (*PubSubResponse) GetPeers ¶
func (m *PubSubResponse) GetPeers() []*PubSubPeer
func (*PubSubResponse) GetRequestType ¶
func (m *PubSubResponse) GetRequestType() PSREQTYPE
func (*PubSubResponse) GetTopics ¶
func (m *PubSubResponse) GetTopics() []string
func (*PubSubResponse) Marshal ¶
func (m *PubSubResponse) Marshal() (dAtA []byte, err error)
func (*PubSubResponse) MarshalToSizedBuffer ¶
func (m *PubSubResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PubSubResponse) ProtoMessage ¶
func (*PubSubResponse) ProtoMessage()
func (*PubSubResponse) Reset ¶
func (m *PubSubResponse) Reset()
func (*PubSubResponse) Size ¶
func (m *PubSubResponse) Size() (n int)
func (*PubSubResponse) String ¶
func (m *PubSubResponse) String() string
func (*PubSubResponse) Unmarshal ¶
func (m *PubSubResponse) Unmarshal(dAtA []byte) error
func (*PubSubResponse) XXX_DiscardUnknown ¶
func (m *PubSubResponse) XXX_DiscardUnknown()
func (*PubSubResponse) XXX_Marshal ¶
func (m *PubSubResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PubSubResponse) XXX_Merge ¶
func (m *PubSubResponse) XXX_Merge(src proto.Message)
func (*PubSubResponse) XXX_Size ¶
func (m *PubSubResponse) XXX_Size() int
func (*PubSubResponse) XXX_Unmarshal ¶
func (m *PubSubResponse) XXX_Unmarshal(b []byte) error
type PutResponse ¶
type PutResponse struct { // hash is hash/cid (content identifier) of the data that was stored Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` }
PutResponse is a response to any data storage (put) requests
func (*PutResponse) Descriptor ¶
func (*PutResponse) Descriptor() ([]byte, []int)
func (*PutResponse) GetHash ¶
func (m *PutResponse) GetHash() string
func (*PutResponse) Marshal ¶
func (m *PutResponse) Marshal() (dAtA []byte, err error)
func (*PutResponse) MarshalToSizedBuffer ¶
func (m *PutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) Reset ¶
func (m *PutResponse) Reset()
func (*PutResponse) Size ¶
func (m *PutResponse) Size() (n int)
func (*PutResponse) String ¶
func (m *PutResponse) String() string
func (*PutResponse) Unmarshal ¶
func (m *PutResponse) Unmarshal(dAtA []byte) error
func (*PutResponse) XXX_DiscardUnknown ¶
func (m *PutResponse) XXX_DiscardUnknown()
func (*PutResponse) XXX_Marshal ¶
func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutResponse) XXX_Merge ¶
func (m *PutResponse) XXX_Merge(src proto.Message)
func (*PutResponse) XXX_Size ¶
func (m *PutResponse) XXX_Size() int
func (*PutResponse) XXX_Unmarshal ¶
func (m *PutResponse) XXX_Unmarshal(b []byte) error
type REFREQOPTS ¶
type REFREQOPTS int32
REFREQOPTS are options for fine-tuning ref count requests
const (
REFREQOPTS_REF_FORCE REFREQOPTS = 0
)
func (REFREQOPTS) EnumDescriptor ¶
func (REFREQOPTS) EnumDescriptor() ([]byte, []int)
func (REFREQOPTS) String ¶
func (x REFREQOPTS) String() string
type REFREQTYPE ¶
type REFREQTYPE int32
REFREQTYPE is used to indicate the type of ref count request being made
const ( // REF_GET_COUNT is used to get the reference count of a particular cid REFREQTYPE_REF_GET_COUNT REFREQTYPE = 0 REFREQTYPE_REF_DELETE REFREQTYPE = 1 )
func (REFREQTYPE) EnumDescriptor ¶
func (REFREQTYPE) EnumDescriptor() ([]byte, []int)
func (REFREQTYPE) String ¶
func (x REFREQTYPE) String() string
type RefCountRequest ¶
type RefCountRequest struct { // cids are optional cids to filter our requests by Cids []string `protobuf:"bytes,1,rep,name=cids,proto3" json:"cids,omitempty"` // can be used to apply limits to the number of store requests made, search limits, etc.. Limit int64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` }
RefCountRequest is used to analyze the reference counter store, and retrieve usage information
func (*RefCountRequest) Descriptor ¶
func (*RefCountRequest) Descriptor() ([]byte, []int)
func (*RefCountRequest) GetCids ¶
func (m *RefCountRequest) GetCids() []string
func (*RefCountRequest) GetLimit ¶
func (m *RefCountRequest) GetLimit() int64
func (*RefCountRequest) Marshal ¶
func (m *RefCountRequest) Marshal() (dAtA []byte, err error)
func (*RefCountRequest) MarshalToSizedBuffer ¶
func (m *RefCountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RefCountRequest) ProtoMessage ¶
func (*RefCountRequest) ProtoMessage()
func (*RefCountRequest) Reset ¶
func (m *RefCountRequest) Reset()
func (*RefCountRequest) Size ¶
func (m *RefCountRequest) Size() (n int)
func (*RefCountRequest) String ¶
func (m *RefCountRequest) String() string
func (*RefCountRequest) Unmarshal ¶
func (m *RefCountRequest) Unmarshal(dAtA []byte) error
func (*RefCountRequest) XXX_DiscardUnknown ¶
func (m *RefCountRequest) XXX_DiscardUnknown()
func (*RefCountRequest) XXX_Marshal ¶
func (m *RefCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RefCountRequest) XXX_Merge ¶
func (m *RefCountRequest) XXX_Merge(src proto.Message)
func (*RefCountRequest) XXX_Size ¶
func (m *RefCountRequest) XXX_Size() int
func (*RefCountRequest) XXX_Unmarshal ¶
func (m *RefCountRequest) XXX_Unmarshal(b []byte) error
type RefCountResponse ¶
type RefCountResponse struct { // cids is a mapping of the cid to its reference count Cids map[string]int64 `` /* 150-byte string literal not displayed */ }
RefCountResponse is used to return the information gathered by a RefCount rpc call.
func (*RefCountResponse) Descriptor ¶
func (*RefCountResponse) Descriptor() ([]byte, []int)
func (*RefCountResponse) GetCids ¶
func (m *RefCountResponse) GetCids() map[string]int64
func (*RefCountResponse) Marshal ¶
func (m *RefCountResponse) Marshal() (dAtA []byte, err error)
func (*RefCountResponse) MarshalToSizedBuffer ¶
func (m *RefCountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RefCountResponse) ProtoMessage ¶
func (*RefCountResponse) ProtoMessage()
func (*RefCountResponse) Reset ¶
func (m *RefCountResponse) Reset()
func (*RefCountResponse) Size ¶
func (m *RefCountResponse) Size() (n int)
func (*RefCountResponse) String ¶
func (m *RefCountResponse) String() string
func (*RefCountResponse) Unmarshal ¶
func (m *RefCountResponse) Unmarshal(dAtA []byte) error
func (*RefCountResponse) XXX_DiscardUnknown ¶
func (m *RefCountResponse) XXX_DiscardUnknown()
func (*RefCountResponse) XXX_Marshal ¶
func (m *RefCountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RefCountResponse) XXX_Merge ¶
func (m *RefCountResponse) XXX_Merge(src proto.Message)
func (*RefCountResponse) XXX_Size ¶
func (m *RefCountResponse) XXX_Size() int
func (*RefCountResponse) XXX_Unmarshal ¶
func (m *RefCountResponse) XXX_Unmarshal(b []byte) error
type StatusAPIClient ¶
type StatusAPIClient interface { // Version is used to retrieve api version information Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionResponse, error) // Status is used to retrieve api status information. Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusResponse, error) }
StatusAPIClient is the client API for StatusAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStatusAPIClient ¶
func NewStatusAPIClient(cc *grpc.ClientConn) StatusAPIClient
type StatusAPIServer ¶
type StatusAPIServer interface { // Version is used to retrieve api version information Version(context.Context, *Empty) (*VersionResponse, error) // Status is used to retrieve api status information. Status(context.Context, *Empty) (*StatusResponse, error) }
StatusAPIServer is the server API for StatusAPI service.
type StatusResponse ¶
type StatusResponse struct { // host is an identifier for the host of the system responding to the request. // it may or may not be the hostname, it is up to the implementer of the service to choose what is here Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // status contains a status enum indicating the state of the system Status APISTATUS `protobuf:"varint,2,opt,name=status,proto3,enum=pb.APISTATUS" json:"status,omitempty"` }
StatusResponse is used to return API status information
func (*StatusResponse) Descriptor ¶
func (*StatusResponse) Descriptor() ([]byte, []int)
func (*StatusResponse) GetHost ¶
func (m *StatusResponse) GetHost() string
func (*StatusResponse) GetStatus ¶
func (m *StatusResponse) GetStatus() APISTATUS
func (*StatusResponse) Marshal ¶
func (m *StatusResponse) Marshal() (dAtA []byte, err error)
func (*StatusResponse) MarshalToSizedBuffer ¶
func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) Reset ¶
func (m *StatusResponse) Reset()
func (*StatusResponse) Size ¶
func (m *StatusResponse) Size() (n int)
func (*StatusResponse) String ¶
func (m *StatusResponse) String() string
func (*StatusResponse) Unmarshal ¶
func (m *StatusResponse) Unmarshal(dAtA []byte) error
func (*StatusResponse) XXX_DiscardUnknown ¶
func (m *StatusResponse) XXX_DiscardUnknown()
func (*StatusResponse) XXX_Marshal ¶
func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusResponse) XXX_Merge ¶
func (m *StatusResponse) XXX_Merge(src proto.Message)
func (*StatusResponse) XXX_Size ¶
func (m *StatusResponse) XXX_Size() int
func (*StatusResponse) XXX_Unmarshal ¶
func (m *StatusResponse) XXX_Unmarshal(b []byte) error
type UnimplementedAdminAPIServer ¶
type UnimplementedAdminAPIServer struct { }
UnimplementedAdminAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedAdminAPIServer) ManageGC ¶
func (*UnimplementedAdminAPIServer) ManageGC(ctx context.Context, req *ManageGCRequest) (*ManageGCResponse, error)
func (*UnimplementedAdminAPIServer) RefCount ¶
func (*UnimplementedAdminAPIServer) RefCount(ctx context.Context, req *RefCountRequest) (*RefCountResponse, error)
type UnimplementedFileAPIServer ¶
type UnimplementedFileAPIServer struct { }
UnimplementedFileAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedFileAPIServer) DownloadFile ¶
func (*UnimplementedFileAPIServer) DownloadFile(req *DownloadRequest, srv FileAPI_DownloadFileServer) error
func (*UnimplementedFileAPIServer) UploadFile ¶
func (*UnimplementedFileAPIServer) UploadFile(srv FileAPI_UploadFileServer) error
type UnimplementedKeystoreAPIServer ¶
type UnimplementedKeystoreAPIServer struct { }
UnimplementedKeystoreAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedKeystoreAPIServer) Keystore ¶
func (*UnimplementedKeystoreAPIServer) Keystore(ctx context.Context, req *KeystoreRequest) (*KeystoreResponse, error)
type UnimplementedNameSysAPIServer ¶
type UnimplementedNameSysAPIServer struct { }
UnimplementedNameSysAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedNameSysAPIServer) NameSysPublish ¶
func (*UnimplementedNameSysAPIServer) NameSysPublish(ctx context.Context, req *NameSysPublishRequest) (*Empty, error)
func (*UnimplementedNameSysAPIServer) NameSysResolve ¶
func (*UnimplementedNameSysAPIServer) NameSysResolve(ctx context.Context, req *NameSysResolveRequest) (*NameSysResolveResult, error)
func (*UnimplementedNameSysAPIServer) NameSysResolveAsync ¶
func (*UnimplementedNameSysAPIServer) NameSysResolveAsync(req *NameSysResolveRequest, srv NameSysAPI_NameSysResolveAsyncServer) error
type UnimplementedNodeAPIServer ¶
type UnimplementedNodeAPIServer struct { }
UnimplementedNodeAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedNodeAPIServer) Blockstore ¶
func (*UnimplementedNodeAPIServer) Blockstore(ctx context.Context, req *BlockstoreRequest) (*BlockstoreResponse, error)
func (*UnimplementedNodeAPIServer) ConnMgmt ¶
func (*UnimplementedNodeAPIServer) ConnMgmt(ctx context.Context, req *ConnMgmtRequest) (*ConnMgmtResponse, error)
func (*UnimplementedNodeAPIServer) Dag ¶
func (*UnimplementedNodeAPIServer) Dag(ctx context.Context, req *DagRequest) (*DagResponse, error)
func (*UnimplementedNodeAPIServer) Extras ¶
func (*UnimplementedNodeAPIServer) Extras(ctx context.Context, req *ExtrasRequest) (*Empty, error)
func (*UnimplementedNodeAPIServer) P2P ¶
func (*UnimplementedNodeAPIServer) P2P(ctx context.Context, req *P2PRequest) (*P2PResponse, error)
type UnimplementedPubSubAPIServer ¶
type UnimplementedPubSubAPIServer struct { }
UnimplementedPubSubAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedPubSubAPIServer) PubSub ¶
func (*UnimplementedPubSubAPIServer) PubSub(srv PubSubAPI_PubSubServer) error
type UnimplementedStatusAPIServer ¶
type UnimplementedStatusAPIServer struct { }
UnimplementedStatusAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedStatusAPIServer) Status ¶
func (*UnimplementedStatusAPIServer) Status(ctx context.Context, req *Empty) (*StatusResponse, error)
func (*UnimplementedStatusAPIServer) Version ¶
func (*UnimplementedStatusAPIServer) Version(ctx context.Context, req *Empty) (*VersionResponse, error)
type UploadOptions ¶
type UploadOptions struct { // specifes the multihash function to use MultiHash string `protobuf:"bytes,1,opt,name=multiHash,proto3" json:"multiHash,omitempty"` // specifies the dag layout (balanced, tricklet) Layout string `protobuf:"bytes,2,opt,name=layout,proto3" json:"layout,omitempty"` // specifies the chunker type (rabin, default, etc...) Chunker string `protobuf:"bytes,3,opt,name=chunker,proto3" json:"chunker,omitempty"` }
UploadOptions allows controlling the parameters of a file upload
func (*UploadOptions) Descriptor ¶
func (*UploadOptions) Descriptor() ([]byte, []int)
func (*UploadOptions) GetChunker ¶
func (m *UploadOptions) GetChunker() string
func (*UploadOptions) GetLayout ¶
func (m *UploadOptions) GetLayout() string
func (*UploadOptions) GetMultiHash ¶
func (m *UploadOptions) GetMultiHash() string
func (*UploadOptions) Marshal ¶
func (m *UploadOptions) Marshal() (dAtA []byte, err error)
func (*UploadOptions) MarshalToSizedBuffer ¶
func (m *UploadOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UploadOptions) ProtoMessage ¶
func (*UploadOptions) ProtoMessage()
func (*UploadOptions) Reset ¶
func (m *UploadOptions) Reset()
func (*UploadOptions) Size ¶
func (m *UploadOptions) Size() (n int)
func (*UploadOptions) String ¶
func (m *UploadOptions) String() string
func (*UploadOptions) Unmarshal ¶
func (m *UploadOptions) Unmarshal(dAtA []byte) error
func (*UploadOptions) XXX_DiscardUnknown ¶
func (m *UploadOptions) XXX_DiscardUnknown()
func (*UploadOptions) XXX_Marshal ¶
func (m *UploadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UploadOptions) XXX_Merge ¶
func (m *UploadOptions) XXX_Merge(src proto.Message)
func (*UploadOptions) XXX_Size ¶
func (m *UploadOptions) XXX_Size() int
func (*UploadOptions) XXX_Unmarshal ¶
func (m *UploadOptions) XXX_Unmarshal(b []byte) error
type UploadRequest ¶
type UploadRequest struct { // blob is a single chunk of data Blob *Blob `protobuf:"bytes,1,opt,name=blob,proto3" json:"blob,omitempty"` // options allows setting the optoins for this upload Options *UploadOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` }
UploadRequest is used to upload data as a UnixFS object
func (*UploadRequest) Descriptor ¶
func (*UploadRequest) Descriptor() ([]byte, []int)
func (*UploadRequest) GetBlob ¶
func (m *UploadRequest) GetBlob() *Blob
func (*UploadRequest) GetOptions ¶
func (m *UploadRequest) GetOptions() *UploadOptions
func (*UploadRequest) Marshal ¶
func (m *UploadRequest) Marshal() (dAtA []byte, err error)
func (*UploadRequest) MarshalToSizedBuffer ¶
func (m *UploadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UploadRequest) ProtoMessage ¶
func (*UploadRequest) ProtoMessage()
func (*UploadRequest) Reset ¶
func (m *UploadRequest) Reset()
func (*UploadRequest) Size ¶
func (m *UploadRequest) Size() (n int)
func (*UploadRequest) String ¶
func (m *UploadRequest) String() string
func (*UploadRequest) Unmarshal ¶
func (m *UploadRequest) Unmarshal(dAtA []byte) error
func (*UploadRequest) XXX_DiscardUnknown ¶
func (m *UploadRequest) XXX_DiscardUnknown()
func (*UploadRequest) XXX_Marshal ¶
func (m *UploadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UploadRequest) XXX_Merge ¶
func (m *UploadRequest) XXX_Merge(src proto.Message)
func (*UploadRequest) XXX_Size ¶
func (m *UploadRequest) XXX_Size() int
func (*UploadRequest) XXX_Unmarshal ¶
func (m *UploadRequest) XXX_Unmarshal(b []byte) error
type VersionResponse ¶
type VersionResponse struct { // version denotes the github version that was present when the api was built Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` }
VersionResponse is used to return API version information
func (*VersionResponse) Descriptor ¶
func (*VersionResponse) Descriptor() ([]byte, []int)
func (*VersionResponse) GetVersion ¶
func (m *VersionResponse) GetVersion() string
func (*VersionResponse) Marshal ¶
func (m *VersionResponse) Marshal() (dAtA []byte, err error)
func (*VersionResponse) MarshalToSizedBuffer ¶
func (m *VersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VersionResponse) ProtoMessage ¶
func (*VersionResponse) ProtoMessage()
func (*VersionResponse) Reset ¶
func (m *VersionResponse) Reset()
func (*VersionResponse) Size ¶
func (m *VersionResponse) Size() (n int)
func (*VersionResponse) String ¶
func (m *VersionResponse) String() string
func (*VersionResponse) Unmarshal ¶
func (m *VersionResponse) Unmarshal(dAtA []byte) error
func (*VersionResponse) XXX_DiscardUnknown ¶
func (m *VersionResponse) XXX_DiscardUnknown()
func (*VersionResponse) XXX_Marshal ¶
func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VersionResponse) XXX_Merge ¶
func (m *VersionResponse) XXX_Merge(src proto.Message)
func (*VersionResponse) XXX_Size ¶
func (m *VersionResponse) XXX_Size() int
func (*VersionResponse) XXX_Unmarshal ¶
func (m *VersionResponse) XXX_Unmarshal(b []byte) error