pb

package
v2.0.0 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2019 License: AGPL-3.0, MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAdmin        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdmin          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDag        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDag          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDag = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthFile        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFile          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFile = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthKeystore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKeystore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupKeystore = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthNamesys        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNamesys          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNamesys = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthNode        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNode          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNode = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPubsub        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPubsub          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPubsub = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStatus        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatus          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStatus = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthUtil        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUtil          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUtil = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var APISTATUS_name = map[int32]string{
	0: "ONLINE",
	1: "PURGING",
	2: "DEGRADED_PERFORMANCE",
	3: "ERROR",
}
View Source 
var APISTATUS_value = map[string]int32{
	"ONLINE":               0,
	"PURGING":              1,
	"DEGRADED_PERFORMANCE": 2,
	"ERROR":                3,
}
View Source 
var BSREQOPTS_name = map[int32]string{
	0: "DEFAULT",
	1: "BS_FORCE",
}
View Source 
var BSREQOPTS_value = map[string]int32{
	"DEFAULT":  0,
	"BS_FORCE": 1,
}
View Source 
var BSREQTYPE_name = map[int32]string{
	0: "BS_DELETE",
	1: "BS_PUT",
	2: "BS_PUT_MANY",
	3: "BS_GET",
	4: "BS_GET_MANY",
}
View Source 
var BSREQTYPE_value = map[string]int32{
	"BS_DELETE":   0,
	"BS_PUT":      1,
	"BS_PUT_MANY": 2,
	"BS_GET":      3,
	"BS_GET_MANY": 4,
}
View Source 
var EXTRASTYPE_name = map[int32]string{
	0: "IDENTIFY",
	1: "PUBSUB",
	2: "DISCOVERY",
	3: "MDNS",
}
View Source 
var EXTRASTYPE_value = map[string]int32{
	"IDENTIFY":  0,
	"PUBSUB":    1,
	"DISCOVERY": 2,
	"MDNS":      3,
}
View Source 
var GCREQTYPE_name = map[int32]string{
	0: "GC_START",
	1: "GC_STOP",
	2: "GC_STATUS",
}
View Source 
var GCREQTYPE_value = map[string]int32{
	"GC_START":  0,
	"GC_STOP":   1,
	"GC_STATUS": 2,
}
View Source 
var P2PREQTYPE_name = map[int32]string{
	0: "CLOSE",
	1: "FORWARD",
	2: "LISTEN",
	3: "LS",
}
View Source 
var P2PREQTYPE_value = map[string]int32{
	"CLOSE":   0,
	"FORWARD": 1,
	"LISTEN":  2,
	"LS":      3,
}
View Source 
var REFREQOPTS_name = map[int32]string{
	0: "REF_FORCE",
}
View Source 
var REFREQOPTS_value = map[string]int32{
	"REF_FORCE": 0,
}
View Source 
var REFREQTYPE_name = map[int32]string{
	0: "REF_GET_COUNT",
	1: "REF_DELETE",
}
View Source 
var REFREQTYPE_value = map[string]int32{
	"REF_GET_COUNT": 0,
	"REF_DELETE":    1,
}

Functions

func RegisterAdminAPIServer 

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

func RegisterDagAPIServer 

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

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 

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

func (APISTATUS) String 

func (x APISTATUS) String() string

type AddLinksRequest 

type AddLinksRequest struct {
	// links are optional hashes to include as links of the node
	// the name is used as the key, while the value of the key is used as the hash
	Links map[string]string `` /* 151-byte string literal not displayed */
	// the hash of the node we want to add lin skto
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// the hash function to to use (sha2-256, sha3-512, etc...)
	HashFunc string `protobuf:"bytes,3,opt,name=hashFunc,proto3" json:"hashFunc,omitempty"`
}

AddLinksRequest is used to add links to an existing ipld node

func (*AddLinksRequest) Descriptor 

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

func (*AddLinksRequest) GetHash 

func (m *AddLinksRequest) GetHash() string

func (*AddLinksRequest) GetHashFunc 

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

func (*AddLinksRequest) Marshal 

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

func (*AddLinksRequest) MarshalTo 

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

func (*AddLinksRequest) MarshalToSizedBuffer 

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

func (*AddLinksRequest) ProtoMessage 

func (*AddLinksRequest) ProtoMessage()

func (*AddLinksRequest) Reset 

func (m *AddLinksRequest) Reset()

func (*AddLinksRequest) Size 

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

func (*AddLinksRequest) String 

func (m *AddLinksRequest) String() string

func (*AddLinksRequest) Unmarshal 

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

func (*AddLinksRequest) XXX_DiscardUnknown 

func (m *AddLinksRequest) XXX_DiscardUnknown()

func (*AddLinksRequest) XXX_Marshal 

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

func (*AddLinksRequest) XXX_Merge 

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

func (*AddLinksRequest) XXX_Size 

func (m *AddLinksRequest) XXX_Size() int

func (*AddLinksRequest) XXX_Unmarshal 

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

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)
	// Blockstore allows management of the blockstore, and optionally, the counted store
	Blockstore(ctx context.Context, in *BlockstoreRequest, opts ...grpc.CallOption) (*BlockstoreResponse, 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)
	// Blockstore allows management of the blockstore, and optionally, the counted store
	Blockstore(context.Context, *BlockstoreRequest) (*BlockstoreResponse, error)
}

AdminAPIServer is the server API for AdminAPI service.

type BSREQOPTS 

type BSREQOPTS int32

BSREQOPTS are options for blockstore requests 

const (
	// DEFAULT indicates to use the default settings
	BSREQOPTS_DEFAULT BSREQOPTS = 0
	// BS_FORCE indicates to force the request regardless of any possible issues
	BSREQOPTS_BS_FORCE BSREQOPTS = 1
)

func (BSREQOPTS) EnumDescriptor 

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

func (BSREQOPTS) String 

func (x BSREQOPTS) String() string

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 

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

func (BSREQTYPE) String 

func (x BSREQTYPE) String() string

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) Descriptor() ([]byte, []int)

func (*Blob) GetContent 

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

func (*Blob) Marshal 

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

func (*Blob) MarshalTo 

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

func (*Blob) MarshalToSizedBuffer 

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

func (*Blob) ProtoMessage 

func (*Blob) ProtoMessage()

func (*Blob) Reset 

func (m *Blob) Reset()

func (*Blob) Size 

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

func (*Blob) String 

func (m *Blob) String() string

func (*Blob) Unmarshal 

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

func (*Blob) XXX_DiscardUnknown 

func (m *Blob) XXX_DiscardUnknown()

func (*Blob) XXX_Marshal 

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

func (*Blob) XXX_Merge 

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

func (*Blob) XXX_Size 

func (m *Blob) XXX_Size() int

func (*Blob) XXX_Unmarshal 

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

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"`
}

Block is a single block of ipfs data

func (*Block) Descriptor 

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

func (*Block) GetCid 

func (m *Block) GetCid() string

func (*Block) GetData 

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

func (*Block) Marshal 

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

func (*Block) MarshalTo 

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

func (*Block) MarshalToSizedBuffer 

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

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) Size 

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

func (*Block) String 

func (m *Block) String() string

func (*Block) Unmarshal 

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

func (*Block) XXX_DiscardUnknown 

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal 

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

func (*Block) XXX_Merge 

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

func (*Block) XXX_Size 

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal 

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

type BlockstoreRequest 

type BlockstoreRequest struct {
	// cids holds at least 1 cid, to hold 0 is considered an error
	Cids []string `protobuf:"bytes,1,rep,name=cids,proto3" json:"cids,omitempty"`
	// reqType is used to indicate the particular request being mande
	ReqType BSREQTYPE `protobuf:"varint,2,opt,name=reqType,proto3,enum=pb.BSREQTYPE" json:"reqType,omitempty"`
	// reqOpts is an optional parameter that can be used for fine-tuned request control
	ReqOpts BSREQOPTS `protobuf:"varint,3,opt,name=reqOpts,proto3,enum=pb.BSREQOPTS" json:"reqOpts,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) GetReqOpts 

func (m *BlockstoreRequest) GetReqOpts() BSREQOPTS

func (*BlockstoreRequest) GetReqType 

func (m *BlockstoreRequest) GetReqType() 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 {
	Blocks []*Block `protobuf:"bytes,1,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) 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 ConnectRequest 

type ConnectRequest struct {
	// a slice of all multiaddrs we want to connect to
	MultiAddrs []string `protobuf:"bytes,1,rep,name=multiAddrs,proto3" json:"multiAddrs,omitempty"`
}

ConnectRequest is used to connect to libp2p peers

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) GetMultiAddrs 

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

func (*ConnectRequest) Marshal 

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

func (*ConnectRequest) MarshalTo 

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

func (*ConnectRequest) MarshalToSizedBuffer 

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

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) Size 

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

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal 

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

func (*ConnectRequest) XXX_DiscardUnknown 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal 

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

func (*ConnectRequest) XXX_Merge 

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

func (*ConnectRequest) XXX_Size 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal 

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

type DagAPIClient 

type DagAPIClient interface {
	// DagPut is used to store arbitrary bytes as a custom IPLD object
	DagPut(ctx context.Context, in *DagPutRequest, opts ...grpc.CallOption) (*DagPutResponse, error)
	// DagGet is used to request the raw ipld node data for an IPLD object
	DagGet(ctx context.Context, in *DagGetRequest, opts ...grpc.CallOption) (*DagGetResponse, error)
	// NewIPLDNode is used to create a new IPFS MerkleDAG node.
	// This is the same type as in github.com/ipfs/go-ipld-format.Node
	NewIPLDNode(ctx context.Context, in *NewIPLDNodeRequest, opts ...grpc.CallOption) (*DagPutResponse, error)
	// AddLinksToNode is used to add links to an existing IPFS MerkleDAG node
	AddLinksToNode(ctx context.Context, in *AddLinksRequest, opts ...grpc.CallOption) (*DagPutResponse, error)
	// GetLinks is used to request all the links for a given object
	GetLinks(ctx context.Context, in *GetLinksRequest, opts ...grpc.CallOption) (*GetLinksResponse, error)
}

DagAPIClient is the client API for DagAPI service.

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

func NewDagAPIClient 

func NewDagAPIClient(cc *grpc.ClientConn) DagAPIClient

type DagAPIServer 

type DagAPIServer interface {
	// DagPut is used to store arbitrary bytes as a custom IPLD object
	DagPut(context.Context, *DagPutRequest) (*DagPutResponse, error)
	// DagGet is used to request the raw ipld node data for an IPLD object
	DagGet(context.Context, *DagGetRequest) (*DagGetResponse, error)
	// NewIPLDNode is used to create a new IPFS MerkleDAG node.
	// This is the same type as in github.com/ipfs/go-ipld-format.Node
	NewIPLDNode(context.Context, *NewIPLDNodeRequest) (*DagPutResponse, error)
	// AddLinksToNode is used to add links to an existing IPFS MerkleDAG node
	AddLinksToNode(context.Context, *AddLinksRequest) (*DagPutResponse, error)
	// GetLinks is used to request all the links for a given object
	GetLinks(context.Context, *GetLinksRequest) (*GetLinksResponse, error)
}

DagAPIServer is the server API for DagAPI service.

type DagGetRequest 

type DagGetRequest struct {
	// the hash of the ipld node to get
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

DagGetRequest is used to retrieve the raw data of an ipld dag node for the specified hash. This can then be used by libraries like go-ipld-format to decoded into a dag object on the client side using merkledag.DecodeProtobuf and passing in the returned bytes

func (*DagGetRequest) Descriptor 

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

func (*DagGetRequest) GetHash 

func (m *DagGetRequest) GetHash() string

func (*DagGetRequest) Marshal 

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

func (*DagGetRequest) MarshalTo 

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

func (*DagGetRequest) MarshalToSizedBuffer 

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

func (*DagGetRequest) ProtoMessage 

func (*DagGetRequest) ProtoMessage()

func (*DagGetRequest) Reset 

func (m *DagGetRequest) Reset()

func (*DagGetRequest) Size 

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

func (*DagGetRequest) String 

func (m *DagGetRequest) String() string

func (*DagGetRequest) Unmarshal 

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

func (*DagGetRequest) XXX_DiscardUnknown 

func (m *DagGetRequest) XXX_DiscardUnknown()

func (*DagGetRequest) XXX_Marshal 

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

func (*DagGetRequest) XXX_Merge 

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

func (*DagGetRequest) XXX_Size 

func (m *DagGetRequest) XXX_Size() int

func (*DagGetRequest) XXX_Unmarshal 

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

type DagGetResponse 

type DagGetResponse struct {
	// the raw data of the ipld node
	RawData []byte `protobuf:"bytes,1,opt,name=rawData,proto3" json:"rawData,omitempty"`
}

DagGetResponse is a response to DagGetRequest that returns the raw data of the matching ipld node

func (*DagGetResponse) Descriptor 

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

func (*DagGetResponse) GetRawData 

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

func (*DagGetResponse) Marshal 

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

func (*DagGetResponse) MarshalTo 

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

func (*DagGetResponse) MarshalToSizedBuffer 

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

func (*DagGetResponse) ProtoMessage 

func (*DagGetResponse) ProtoMessage()

func (*DagGetResponse) Reset 

func (m *DagGetResponse) Reset()

func (*DagGetResponse) Size 

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

func (*DagGetResponse) String 

func (m *DagGetResponse) String() string

func (*DagGetResponse) Unmarshal 

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

func (*DagGetResponse) XXX_DiscardUnknown 

func (m *DagGetResponse) XXX_DiscardUnknown()

func (*DagGetResponse) XXX_Marshal 

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

func (*DagGetResponse) XXX_Merge 

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

func (*DagGetResponse) XXX_Size 

func (m *DagGetResponse) XXX_Size() int

func (*DagGetResponse) XXX_Unmarshal 

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

type DagPutRequest 

type DagPutRequest struct {
	// data that we will be storing
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// the object encoding type (raw, cbor, protobuf, etc...)
	ObjectEncoding string `protobuf:"bytes,2,opt,name=objectEncoding,proto3" json:"objectEncoding,omitempty"`
	// the serialization format (raw, cbor, protobuf, etc...)
	SerializationFormat string `protobuf:"bytes,3,opt,name=serializationFormat,proto3" json:"serializationFormat,omitempty"`
	// the hash function to to use (sha2-256, sha3-512, etc...)
	HashFunc string `protobuf:"bytes,4,opt,name=hashFunc,proto3" json:"hashFunc,omitempty"`
	// the cid version to use (0, 1)
	CidVersion int64 `protobuf:"varint,5,opt,name=cidVersion,proto3" json:"cidVersion,omitempty"`
}

DagPut allows us to store arbitrary bytes as a custom IPLD object

func (*DagPutRequest) Descriptor 

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

func (*DagPutRequest) GetCidVersion 

func (m *DagPutRequest) GetCidVersion() int64

func (*DagPutRequest) GetData 

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

func (*DagPutRequest) GetHashFunc 

func (m *DagPutRequest) GetHashFunc() string

func (*DagPutRequest) GetObjectEncoding 

func (m *DagPutRequest) GetObjectEncoding() string

func (*DagPutRequest) GetSerializationFormat 

func (m *DagPutRequest) GetSerializationFormat() string

func (*DagPutRequest) Marshal 

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

func (*DagPutRequest) MarshalTo 

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

func (*DagPutRequest) MarshalToSizedBuffer 

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

func (*DagPutRequest) ProtoMessage 

func (*DagPutRequest) ProtoMessage()

func (*DagPutRequest) Reset 

func (m *DagPutRequest) Reset()

func (*DagPutRequest) Size 

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

func (*DagPutRequest) String 

func (m *DagPutRequest) String() string

func (*DagPutRequest) Unmarshal 

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

func (*DagPutRequest) XXX_DiscardUnknown 

func (m *DagPutRequest) XXX_DiscardUnknown()

func (*DagPutRequest) XXX_Marshal 

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

func (*DagPutRequest) XXX_Merge 

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

func (*DagPutRequest) XXX_Size 

func (m *DagPutRequest) XXX_Size() int

func (*DagPutRequest) XXX_Unmarshal 

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

type DagPutResponse 

type DagPutResponse struct {
	// an array of hashes (cids) of the root ipld nod
	Hashes []string `protobuf:"bytes,1,rep,name=hashes,proto3" json:"hashes,omitempty"`
}

DagPutResponse contains the hashes of ipld nodes generated by the dag put request

func (*DagPutResponse) Descriptor 

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

func (*DagPutResponse) GetHashes 

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

func (*DagPutResponse) Marshal 

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

func (*DagPutResponse) MarshalTo 

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

func (*DagPutResponse) MarshalToSizedBuffer 

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

func (*DagPutResponse) ProtoMessage 

func (*DagPutResponse) ProtoMessage()

func (*DagPutResponse) Reset 

func (m *DagPutResponse) Reset()

func (*DagPutResponse) Size 

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

func (*DagPutResponse) String 

func (m *DagPutResponse) String() string

func (*DagPutResponse) Unmarshal 

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

func (*DagPutResponse) XXX_DiscardUnknown 

func (m *DagPutResponse) XXX_DiscardUnknown()

func (*DagPutResponse) XXX_Marshal 

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

func (*DagPutResponse) XXX_Merge 

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

func (*DagPutResponse) XXX_Size 

func (m *DagPutResponse) XXX_Size() int

func (*DagPutResponse) XXX_Unmarshal 

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

type DisableExtrasRequest 

type DisableExtrasRequest struct {
	// extrasFeature denotes the particular extras functionality to disable
	ExtrasFeature EXTRASTYPE `protobuf:"varint,1,opt,name=extrasFeature,proto3,enum=pb.EXTRASTYPE" json:"extrasFeature,omitempty"`
}

DisableExtrasRequest is used to disable a particular extras feature

func (*DisableExtrasRequest) Descriptor 

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

func (*DisableExtrasRequest) GetExtrasFeature 

func (m *DisableExtrasRequest) GetExtrasFeature() EXTRASTYPE

func (*DisableExtrasRequest) Marshal 

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

func (*DisableExtrasRequest) MarshalTo 

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

func (*DisableExtrasRequest) MarshalToSizedBuffer 

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

func (*DisableExtrasRequest) ProtoMessage 

func (*DisableExtrasRequest) ProtoMessage()

func (*DisableExtrasRequest) Reset 

func (m *DisableExtrasRequest) Reset()

func (*DisableExtrasRequest) Size 

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

func (*DisableExtrasRequest) String 

func (m *DisableExtrasRequest) String() string

func (*DisableExtrasRequest) Unmarshal 

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

func (*DisableExtrasRequest) XXX_DiscardUnknown 

func (m *DisableExtrasRequest) XXX_DiscardUnknown()

func (*DisableExtrasRequest) XXX_Marshal 

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

func (*DisableExtrasRequest) XXX_Merge 

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

func (*DisableExtrasRequest) XXX_Size 

func (m *DisableExtrasRequest) XXX_Size() int

func (*DisableExtrasRequest) XXX_Unmarshal 

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

type DisconnectRequest 

type DisconnectRequest struct {
	// a slice of the peer IDs to disconnect from
	PeerIDs []string `protobuf:"bytes,1,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"`
}

DisconnectRequest is used to disconnect a connection to a libp2p peer

func (*DisconnectRequest) Descriptor 

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

func (*DisconnectRequest) GetPeerIDs 

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

func (*DisconnectRequest) Marshal 

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

func (*DisconnectRequest) MarshalTo 

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

func (*DisconnectRequest) MarshalToSizedBuffer 

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

func (*DisconnectRequest) ProtoMessage 

func (*DisconnectRequest) ProtoMessage()

func (*DisconnectRequest) Reset 

func (m *DisconnectRequest) Reset()

func (*DisconnectRequest) Size 

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

func (*DisconnectRequest) String 

func (m *DisconnectRequest) String() string

func (*DisconnectRequest) Unmarshal 

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

func (*DisconnectRequest) XXX_DiscardUnknown 

func (m *DisconnectRequest) XXX_DiscardUnknown()

func (*DisconnectRequest) XXX_Marshal 

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

func (*DisconnectRequest) XXX_Merge 

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

func (*DisconnectRequest) XXX_Size 

func (m *DisconnectRequest) XXX_Size() int

func (*DisconnectRequest) XXX_Unmarshal 

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

type DisconnectResponse 

type DisconnectResponse struct {
	// a map of the peer id, and a custom message indicating success, or why there was a failure
	Status map[string]*DisconnectResponse_StatusMessage `` /* 153-byte string literal not displayed */
}

DisconnectResponse is a response to a disconnect request

func (*DisconnectResponse) Descriptor 

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

func (*DisconnectResponse) GetStatus 

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

func (*DisconnectResponse) Marshal 

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

func (*DisconnectResponse) MarshalTo 

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

func (*DisconnectResponse) MarshalToSizedBuffer 

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

func (*DisconnectResponse) ProtoMessage 

func (*DisconnectResponse) ProtoMessage()

func (*DisconnectResponse) Reset 

func (m *DisconnectResponse) Reset()

func (*DisconnectResponse) Size 

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

func (*DisconnectResponse) String 

func (m *DisconnectResponse) String() string

func (*DisconnectResponse) Unmarshal 

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

func (*DisconnectResponse) XXX_DiscardUnknown 

func (m *DisconnectResponse) XXX_DiscardUnknown()

func (*DisconnectResponse) XXX_Marshal 

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

func (*DisconnectResponse) XXX_Merge 

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

func (*DisconnectResponse) XXX_Size 

func (m *DisconnectResponse) XXX_Size() int

func (*DisconnectResponse) XXX_Unmarshal 

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

type DisconnectResponse_StatusMessage 

type DisconnectResponse_StatusMessage 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"`
}

StatusMessage is used to contain the status information about a particular disconnection attempt

func (*DisconnectResponse_StatusMessage) Descriptor 

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

func (*DisconnectResponse_StatusMessage) GetDisconnected 

func (m *DisconnectResponse_StatusMessage) GetDisconnected() bool

func (*DisconnectResponse_StatusMessage) GetReason 

func (m *DisconnectResponse_StatusMessage) GetReason() string

func (*DisconnectResponse_StatusMessage) Marshal 

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

func (*DisconnectResponse_StatusMessage) MarshalTo 

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

func (*DisconnectResponse_StatusMessage) MarshalToSizedBuffer 

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

func (*DisconnectResponse_StatusMessage) ProtoMessage 

func (*DisconnectResponse_StatusMessage) ProtoMessage()

func (*DisconnectResponse_StatusMessage) Reset 

func (m *DisconnectResponse_StatusMessage) Reset()

func (*DisconnectResponse_StatusMessage) Size 

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

func (*DisconnectResponse_StatusMessage) String 

func (m *DisconnectResponse_StatusMessage) String() string

func (*DisconnectResponse_StatusMessage) Unmarshal 

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

func (*DisconnectResponse_StatusMessage) XXX_DiscardUnknown 

func (m *DisconnectResponse_StatusMessage) XXX_DiscardUnknown()

func (*DisconnectResponse_StatusMessage) XXX_Marshal 

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

func (*DisconnectResponse_StatusMessage) XXX_Merge 

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

func (*DisconnectResponse_StatusMessage) XXX_Size 

func (m *DisconnectResponse_StatusMessage) XXX_Size() int

func (*DisconnectResponse_StatusMessage) XXX_Unmarshal 

func (m *DisconnectResponse_StatusMessage) 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) MarshalTo 

func (m *DownloadRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *DownloadResponse) MarshalTo(dAtA []byte) (int, 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 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) Descriptor() ([]byte, []int)

func (*Empty) Marshal 

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

func (*Empty) MarshalTo 

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

func (*Empty) MarshalToSizedBuffer 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

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

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

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

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type EnableExtrasRequest 

type EnableExtrasRequest struct {
	// extrasFeature denotes the particular extras functionality to enable
	ExtrasFeature EXTRASTYPE `protobuf:"varint,1,opt,name=extrasFeature,proto3,enum=pb.EXTRASTYPE" json:"extrasFeature,omitempty"`
}

EnableExtrasRequest is used to enable a particular extras feature

func (*EnableExtrasRequest) Descriptor 

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

func (*EnableExtrasRequest) GetExtrasFeature 

func (m *EnableExtrasRequest) GetExtrasFeature() EXTRASTYPE

func (*EnableExtrasRequest) Marshal 

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

func (*EnableExtrasRequest) MarshalTo 

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

func (*EnableExtrasRequest) MarshalToSizedBuffer 

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

func (*EnableExtrasRequest) ProtoMessage 

func (*EnableExtrasRequest) ProtoMessage()

func (*EnableExtrasRequest) Reset 

func (m *EnableExtrasRequest) Reset()

func (*EnableExtrasRequest) Size 

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

func (*EnableExtrasRequest) String 

func (m *EnableExtrasRequest) String() string

func (*EnableExtrasRequest) Unmarshal 

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

func (*EnableExtrasRequest) XXX_DiscardUnknown 

func (m *EnableExtrasRequest) XXX_DiscardUnknown()

func (*EnableExtrasRequest) XXX_Marshal 

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

func (*EnableExtrasRequest) XXX_Merge 

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

func (*EnableExtrasRequest) XXX_Size 

func (m *EnableExtrasRequest) XXX_Size() int

func (*EnableExtrasRequest) XXX_Unmarshal 

func (m *EnableExtrasRequest) 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 

const (
	// GC_START is used to start gc
	GCREQTYPE_GC_START GCREQTYPE = 0
	// C_STOP is used to stop GC
	GCREQTYPE_GC_STOP GCREQTYPE = 1
	// GC_STATUS is used to retrieve gc status
	GCREQTYPE_GC_STATUS GCREQTYPE = 2
)

func (GCREQTYPE) EnumDescriptor 

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

func (GCREQTYPE) String 

func (x GCREQTYPE) String() string

type GetLinksRequest 

type GetLinksRequest struct {
	// the hash to request links for
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

GetLinksRequest is used to return all the links associated with a particular hash

func (*GetLinksRequest) Descriptor 

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

func (*GetLinksRequest) GetHash 

func (m *GetLinksRequest) GetHash() string

func (*GetLinksRequest) Marshal 

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

func (*GetLinksRequest) MarshalTo 

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

func (*GetLinksRequest) MarshalToSizedBuffer 

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

func (*GetLinksRequest) ProtoMessage 

func (*GetLinksRequest) ProtoMessage()

func (*GetLinksRequest) Reset 

func (m *GetLinksRequest) Reset()

func (*GetLinksRequest) Size 

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

func (*GetLinksRequest) String 

func (m *GetLinksRequest) String() string

func (*GetLinksRequest) Unmarshal 

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

func (*GetLinksRequest) XXX_DiscardUnknown 

func (m *GetLinksRequest) XXX_DiscardUnknown()

func (*GetLinksRequest) XXX_Marshal 

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

func (*GetLinksRequest) XXX_Merge 

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

func (*GetLinksRequest) XXX_Size 

func (m *GetLinksRequest) XXX_Size() int

func (*GetLinksRequest) XXX_Unmarshal 

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

type GetLinksResponse 

type GetLinksResponse struct {
	// each of the links referenced by the requested hash
	Links []*IPLDLink `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
}

GetLinksResponse returns all the links for the associated hash that was requested

func (*GetLinksResponse) Descriptor 

func (*GetLinksResponse) Descriptor() ([]byte, []int)
func (m *GetLinksResponse) GetLinks() []*IPLDLink

func (*GetLinksResponse) Marshal 

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

func (*GetLinksResponse) MarshalTo 

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

func (*GetLinksResponse) MarshalToSizedBuffer 

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

func (*GetLinksResponse) ProtoMessage 

func (*GetLinksResponse) ProtoMessage()

func (*GetLinksResponse) Reset 

func (m *GetLinksResponse) Reset()

func (*GetLinksResponse) Size 

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

func (*GetLinksResponse) String 

func (m *GetLinksResponse) String() string

func (*GetLinksResponse) Unmarshal 

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

func (*GetLinksResponse) XXX_DiscardUnknown 

func (m *GetLinksResponse) XXX_DiscardUnknown()

func (*GetLinksResponse) XXX_Marshal 

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

func (*GetLinksResponse) XXX_Merge 

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

func (*GetLinksResponse) XXX_Size 

func (m *GetLinksResponse) XXX_Size() int

func (*GetLinksResponse) XXX_Unmarshal 

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

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) MarshalTo 

func (m *GetPeersResponse) MarshalTo(dAtA []byte) (int, 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 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) Descriptor() ([]byte, []int)

func (*IPLDLink) GetHash 

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

func (*IPLDLink) GetName 

func (m *IPLDLink) GetName() string

func (*IPLDLink) GetSize_ 

func (m *IPLDLink) GetSize_() uint64

func (*IPLDLink) Marshal 

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

func (*IPLDLink) MarshalTo 

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

func (*IPLDLink) MarshalToSizedBuffer 

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

func (*IPLDLink) ProtoMessage 

func (*IPLDLink) ProtoMessage()

func (*IPLDLink) Reset 

func (m *IPLDLink) Reset()

func (*IPLDLink) Size 

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

func (*IPLDLink) String 

func (m *IPLDLink) String() string

func (*IPLDLink) Unmarshal 

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

func (*IPLDLink) XXX_DiscardUnknown 

func (m *IPLDLink) XXX_DiscardUnknown()

func (*IPLDLink) XXX_Marshal 

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

func (*IPLDLink) XXX_Merge 

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

func (*IPLDLink) XXX_Size 

func (m *IPLDLink) XXX_Size() int

func (*IPLDLink) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*IPLDNode) GetData 

func (m *IPLDNode) GetData() []byte
func (m *IPLDNode) GetLinks() []*IPLDLink

func (*IPLDNode) Marshal 

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

func (*IPLDNode) MarshalTo 

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

func (*IPLDNode) MarshalToSizedBuffer 

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

func (*IPLDNode) ProtoMessage 

func (*IPLDNode) ProtoMessage()

func (*IPLDNode) Reset 

func (m *IPLDNode) Reset()

func (*IPLDNode) Size 

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

func (*IPLDNode) String 

func (m *IPLDNode) String() string

func (*IPLDNode) Unmarshal 

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

func (*IPLDNode) XXX_DiscardUnknown 

func (m *IPLDNode) XXX_DiscardUnknown()

func (*IPLDNode) XXX_Marshal 

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

func (*IPLDNode) XXX_Merge 

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

func (*IPLDNode) XXX_Size 

func (m *IPLDNode) XXX_Size() int

func (*IPLDNode) XXX_Unmarshal 

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

type IsConnectedRequest 

type IsConnectedRequest struct {
	// a slice of the peer IDs to examine
	PeerIDs []string `protobuf:"bytes,1,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"`
}

IsConnectedRequest is used check whether or not we are currently peered with these peers

func (*IsConnectedRequest) Descriptor 

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

func (*IsConnectedRequest) GetPeerIDs 

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

func (*IsConnectedRequest) Marshal 

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

func (*IsConnectedRequest) MarshalTo 

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

func (*IsConnectedRequest) MarshalToSizedBuffer 

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

func (*IsConnectedRequest) ProtoMessage 

func (*IsConnectedRequest) ProtoMessage()

func (*IsConnectedRequest) Reset 

func (m *IsConnectedRequest) Reset()

func (*IsConnectedRequest) Size 

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

func (*IsConnectedRequest) String 

func (m *IsConnectedRequest) String() string

func (*IsConnectedRequest) Unmarshal 

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

func (*IsConnectedRequest) XXX_DiscardUnknown 

func (m *IsConnectedRequest) XXX_DiscardUnknown()

func (*IsConnectedRequest) XXX_Marshal 

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

func (*IsConnectedRequest) XXX_Merge 

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

func (*IsConnectedRequest) XXX_Size 

func (m *IsConnectedRequest) XXX_Size() int

func (*IsConnectedRequest) XXX_Unmarshal 

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

type IsConnectedResponse 

type IsConnectedResponse struct {
	// a map of the peer ID and a boolean indicating if we are connected with them
	Connected map[string]bool `` /* 160-byte string literal not displayed */
}

IsConnectedResponse is a response to an IsConnectedRequest request

func (*IsConnectedResponse) Descriptor 

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

func (*IsConnectedResponse) GetConnected 

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

func (*IsConnectedResponse) Marshal 

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

func (*IsConnectedResponse) MarshalTo 

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

func (*IsConnectedResponse) MarshalToSizedBuffer 

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

func (*IsConnectedResponse) ProtoMessage 

func (*IsConnectedResponse) ProtoMessage()

func (*IsConnectedResponse) Reset 

func (m *IsConnectedResponse) Reset()

func (*IsConnectedResponse) Size 

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

func (*IsConnectedResponse) String 

func (m *IsConnectedResponse) String() string

func (*IsConnectedResponse) Unmarshal 

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

func (*IsConnectedResponse) XXX_DiscardUnknown 

func (m *IsConnectedResponse) XXX_DiscardUnknown()

func (*IsConnectedResponse) XXX_Marshal 

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

func (*IsConnectedResponse) XXX_Merge 

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

func (*IsConnectedResponse) XXX_Size 

func (m *IsConnectedResponse) XXX_Size() int

func (*IsConnectedResponse) XXX_Unmarshal 

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

type KeystoreAPIClient 

type KeystoreAPIClient interface {
	// KeystoreHas is used to check if we have the key in our store
	KeystoreHas(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)
	// KeystoreGet is used to return a key from our store
	KeystoreGet(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)
	// KeystorePut is used to store a key in our store
	KeystorePut(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)
	// KeystoreDelete is used to remove a key from our store
	KeystoreDelete(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)
	// KeystoreList is used to returns all keyIDs of keys in our store
	KeystoreList(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 {
	// KeystoreHas is used to check if we have the key in our store
	KeystoreHas(context.Context, *KeystoreRequest) (*KeystoreResponse, error)
	// KeystoreGet is used to return a key from our store
	KeystoreGet(context.Context, *KeystoreRequest) (*KeystoreResponse, error)
	// KeystorePut is used to store a key in our store
	KeystorePut(context.Context, *KeystoreRequest) (*KeystoreResponse, error)
	// KeystoreDelete is used to remove a key from our store
	KeystoreDelete(context.Context, *KeystoreRequest) (*KeystoreResponse, error)
	// KeystoreList is used to returns all keyIDs of keys in our store
	KeystoreList(context.Context, *KeystoreRequest) (*KeystoreResponse, error)
}

KeystoreAPIServer is the server API for KeystoreAPI service.

type KeystoreRequest 

type KeystoreRequest struct {
	// name of the key the request is for
	// applicable to: has, get, put, delete
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the actual private key
	// applicable to: put
	PrivateKey []byte `protobuf:"bytes,2,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
}

KeystoreRequest is a message used in any keystore API request

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) Marshal 

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

func (*KeystoreRequest) MarshalTo 

func (m *KeystoreRequest) MarshalTo(dAtA []byte) (int, 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 {
	// a generic status message
	// returned by Has requests, and may or may not
	// be returned by other requests
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// the actual private key
	// returned by Get requests
	PrivateKey []byte `protobuf:"bytes,2,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
	// names of keys returned by a List request
	KeyNames []string `protobuf:"bytes,3,rep,name=keyNames,proto3" json:"keyNames,omitempty"`
}

KeystoreResponse is a responsed to any keystore API request

func (*KeystoreResponse) Descriptor 

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

func (*KeystoreResponse) GetKeyNames 

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

func (*KeystoreResponse) GetPrivateKey 

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

func (*KeystoreResponse) GetStatus 

func (m *KeystoreResponse) GetStatus() string

func (*KeystoreResponse) Marshal 

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

func (*KeystoreResponse) MarshalTo 

func (m *KeystoreResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ManageGCRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ManageGCResponse) MarshalTo(dAtA []byte) (int, 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 NewIPLDNodeRequest 

type NewIPLDNodeRequest struct {
	// links are optional hashes to include as links of the node
	// the name is used as the key, while the value of the key is used as the hash
	Links map[string]string `` /* 151-byte string literal not displayed */
	// data to store as part of the data field
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// the hash function to to use (sha2-256, sha3-512, etc...)
	HashFunc string `protobuf:"bytes,3,opt,name=hashFunc,proto3" json:"hashFunc,omitempty"`
}

NewIPLDNodeRequest is used to create a new ipld node

func (*NewIPLDNodeRequest) Descriptor 

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

func (*NewIPLDNodeRequest) GetData 

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

func (*NewIPLDNodeRequest) GetHashFunc 

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

func (*NewIPLDNodeRequest) Marshal 

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

func (*NewIPLDNodeRequest) MarshalTo 

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

func (*NewIPLDNodeRequest) MarshalToSizedBuffer 

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

func (*NewIPLDNodeRequest) ProtoMessage 

func (*NewIPLDNodeRequest) ProtoMessage()

func (*NewIPLDNodeRequest) Reset 

func (m *NewIPLDNodeRequest) Reset()

func (*NewIPLDNodeRequest) Size 

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

func (*NewIPLDNodeRequest) String 

func (m *NewIPLDNodeRequest) String() string

func (*NewIPLDNodeRequest) Unmarshal 

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

func (*NewIPLDNodeRequest) XXX_DiscardUnknown 

func (m *NewIPLDNodeRequest) XXX_DiscardUnknown()

func (*NewIPLDNodeRequest) XXX_Marshal 

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

func (*NewIPLDNodeRequest) XXX_Merge 

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

func (*NewIPLDNodeRequest) XXX_Size 

func (m *NewIPLDNodeRequest) XXX_Size() int

func (*NewIPLDNodeRequest) XXX_Unmarshal 

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

type NodeAPIClient 

type NodeAPIClient interface {
	// GetPeers returns a message containing a slice of current peers in our peerstore
	GetPeers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetPeersResponse, error)
	// Connect is used to connect to remote libp2p peers
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*Empty, error)
	// Disconnect is used to disconnect remote libp2p peer connections
	Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error)
	// IsConnected is used to check if we are connected with a given peer
	IsConnected(ctx context.Context, in *IsConnectedRequest, opts ...grpc.CallOption) (*IsConnectedResponse, error)
	// EnableExtras is used to enable a particular extras feature
	EnableExtras(ctx context.Context, in *EnableExtrasRequest, opts ...grpc.CallOption) (*Empty, error)
	// DisableExtras is used to disable a particular extras feature
	DisableExtras(ctx context.Context, in *DisableExtrasRequest, 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)
}

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 {
	// GetPeers returns a message containing a slice of current peers in our peerstore
	GetPeers(context.Context, *Empty) (*GetPeersResponse, error)
	// Connect is used to connect to remote libp2p peers
	Connect(context.Context, *ConnectRequest) (*Empty, error)
	// Disconnect is used to disconnect remote libp2p peer connections
	Disconnect(context.Context, *DisconnectRequest) (*DisconnectResponse, error)
	// IsConnected is used to check if we are connected with a given peer
	IsConnected(context.Context, *IsConnectedRequest) (*IsConnectedResponse, error)
	// EnableExtras is used to enable a particular extras feature
	EnableExtras(context.Context, *EnableExtrasRequest) (*Empty, error)
	// DisableExtras is used to disable a particular extras feature
	DisableExtras(context.Context, *DisableExtrasRequest) (*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)
}

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) Descriptor() ([]byte, []int)

func (*P2PLsInfo) GetListenAddress 

func (m *P2PLsInfo) GetListenAddress() string

func (*P2PLsInfo) GetLocal 

func (m *P2PLsInfo) GetLocal() bool

func (*P2PLsInfo) GetProtocolName 

func (m *P2PLsInfo) GetProtocolName() string

func (*P2PLsInfo) GetTargetAddress 

func (m *P2PLsInfo) GetTargetAddress() string

func (*P2PLsInfo) Marshal 

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

func (*P2PLsInfo) MarshalTo 

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

func (*P2PLsInfo) MarshalToSizedBuffer 

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

func (*P2PLsInfo) ProtoMessage 

func (*P2PLsInfo) ProtoMessage()

func (*P2PLsInfo) Reset 

func (m *P2PLsInfo) Reset()

func (*P2PLsInfo) Size 

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

func (*P2PLsInfo) String 

func (m *P2PLsInfo) String() string

func (*P2PLsInfo) Unmarshal 

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

func (*P2PLsInfo) XXX_DiscardUnknown 

func (m *P2PLsInfo) XXX_DiscardUnknown()

func (*P2PLsInfo) XXX_Marshal 

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

func (*P2PLsInfo) XXX_Merge 

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

func (*P2PLsInfo) XXX_Size 

func (m *P2PLsInfo) XXX_Size() int

func (*P2PLsInfo) XXX_Unmarshal 

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

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) MarshalTo 

func (m *P2PRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *P2PResponse) MarshalTo(dAtA []byte) (int, 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 PubSubAPIClient 

type PubSubAPIClient interface {
	// PubSubGetTopics is used to return a list of all
	// known topics the pubsub instance is subscribed to.
	PubSubGetTopics(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PubSubTopicsResponse, error)
	// PubSubListPeers is used to return a list of peers subscribed
	// to a given topic or topics.
	PubSubListPeers(ctx context.Context, in *PubSubListPeersRequest, opts ...grpc.CallOption) (*PubSubListPeersResponse, error)
	// PubSubSubscribe is used to subscribe to a topic and receive messages
	// Server will stream the messages received on the topic specified
	// during the initial subscription call, and send each message
	// back to the client as it is received.
	PubSubSubscribe(ctx context.Context, in *PubSubSubscribeRequest, opts ...grpc.CallOption) (PubSubAPI_PubSubSubscribeClient, error)
	// PubSubPublish is used to send a stream of messages to a pubsub topic.
	PubSubPublish(ctx context.Context, opts ...grpc.CallOption) (PubSubAPI_PubSubPublishClient, 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 {
	// PubSubGetTopics is used to return a list of all
	// known topics the pubsub instance is subscribed to.
	PubSubGetTopics(context.Context, *Empty) (*PubSubTopicsResponse, error)
	// PubSubListPeers is used to return a list of peers subscribed
	// to a given topic or topics.
	PubSubListPeers(context.Context, *PubSubListPeersRequest) (*PubSubListPeersResponse, error)
	// PubSubSubscribe is used to subscribe to a topic and receive messages
	// Server will stream the messages received on the topic specified
	// during the initial subscription call, and send each message
	// back to the client as it is received.
	PubSubSubscribe(*PubSubSubscribeRequest, PubSubAPI_PubSubSubscribeServer) error
	// PubSubPublish is used to send a stream of messages to a pubsub topic.
	PubSubPublish(PubSubAPI_PubSubPublishServer) error
}

PubSubAPIServer is the server API for PubSubAPI service.

type PubSubAPI_PubSubPublishClient 

type PubSubAPI_PubSubPublishClient interface {
	Send(*PubSubPublishRequest) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type PubSubAPI_PubSubPublishServer 

type PubSubAPI_PubSubPublishServer interface {
	SendAndClose(*Empty) error
	Recv() (*PubSubPublishRequest, error)
	grpc.ServerStream
}

type PubSubAPI_PubSubSubscribeClient 

type PubSubAPI_PubSubSubscribeClient interface {
	Recv() (*PubSubMessageResponse, error)
	grpc.ClientStream
}

type PubSubAPI_PubSubSubscribeServer 

type PubSubAPI_PubSubSubscribeServer interface {
	Send(*PubSubMessageResponse) error
	grpc.ServerStream
}

type PubSubListPeersRequest 

type PubSubListPeersRequest struct {
	// the topics for which we should
	// list peers for
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
}

PubSubListPeersRequest is used to return a list of peers that are subscribed to the given topic(s)

func (*PubSubListPeersRequest) Descriptor 

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

func (*PubSubListPeersRequest) GetTopics 

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

func (*PubSubListPeersRequest) Marshal 

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

func (*PubSubListPeersRequest) MarshalTo 

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

func (*PubSubListPeersRequest) MarshalToSizedBuffer 

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

func (*PubSubListPeersRequest) ProtoMessage 

func (*PubSubListPeersRequest) ProtoMessage()

func (*PubSubListPeersRequest) Reset 

func (m *PubSubListPeersRequest) Reset()

func (*PubSubListPeersRequest) Size 

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

func (*PubSubListPeersRequest) String 

func (m *PubSubListPeersRequest) String() string

func (*PubSubListPeersRequest) Unmarshal 

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

func (*PubSubListPeersRequest) XXX_DiscardUnknown 

func (m *PubSubListPeersRequest) XXX_DiscardUnknown()

func (*PubSubListPeersRequest) XXX_Marshal 

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

func (*PubSubListPeersRequest) XXX_Merge 

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

func (*PubSubListPeersRequest) XXX_Size 

func (m *PubSubListPeersRequest) XXX_Size() int

func (*PubSubListPeersRequest) XXX_Unmarshal 

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

type PubSubListPeersResponse 

type PubSubListPeersResponse struct {
	Peers []*PubSubListPeersResponse_Peer `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
}

PubSubListPeersResponse is a response to a ListPeersRequest

func (*PubSubListPeersResponse) Descriptor 

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

func (*PubSubListPeersResponse) GetPeers 

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

func (*PubSubListPeersResponse) Marshal 

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

func (*PubSubListPeersResponse) MarshalTo 

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

func (*PubSubListPeersResponse) MarshalToSizedBuffer 

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

func (*PubSubListPeersResponse) ProtoMessage 

func (*PubSubListPeersResponse) ProtoMessage()

func (*PubSubListPeersResponse) Reset 

func (m *PubSubListPeersResponse) Reset()

func (*PubSubListPeersResponse) Size 

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

func (*PubSubListPeersResponse) String 

func (m *PubSubListPeersResponse) String() string

func (*PubSubListPeersResponse) Unmarshal 

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

func (*PubSubListPeersResponse) XXX_DiscardUnknown 

func (m *PubSubListPeersResponse) XXX_DiscardUnknown()

func (*PubSubListPeersResponse) XXX_Marshal 

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

func (*PubSubListPeersResponse) XXX_Merge 

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

func (*PubSubListPeersResponse) XXX_Size 

func (m *PubSubListPeersResponse) XXX_Size() int

func (*PubSubListPeersResponse) XXX_Unmarshal 

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

type PubSubListPeersResponse_Peer 

type PubSubListPeersResponse_Peer struct {
	// topic is the topic this peer is a part of
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// lists the peerid for this peer
	PeerID string `protobuf:"bytes,2,opt,name=peerID,proto3" json:"peerID,omitempty"`
}

peer is a single peer

func (*PubSubListPeersResponse_Peer) Descriptor 

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

func (*PubSubListPeersResponse_Peer) GetPeerID 

func (m *PubSubListPeersResponse_Peer) GetPeerID() string

func (*PubSubListPeersResponse_Peer) GetTopic 

func (m *PubSubListPeersResponse_Peer) GetTopic() string

func (*PubSubListPeersResponse_Peer) Marshal 

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

func (*PubSubListPeersResponse_Peer) MarshalTo 

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

func (*PubSubListPeersResponse_Peer) MarshalToSizedBuffer 

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

func (*PubSubListPeersResponse_Peer) ProtoMessage 

func (*PubSubListPeersResponse_Peer) ProtoMessage()

func (*PubSubListPeersResponse_Peer) Reset 

func (m *PubSubListPeersResponse_Peer) Reset()

func (*PubSubListPeersResponse_Peer) Size 

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

func (*PubSubListPeersResponse_Peer) String 

func (m *PubSubListPeersResponse_Peer) String() string

func (*PubSubListPeersResponse_Peer) Unmarshal 

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

func (*PubSubListPeersResponse_Peer) XXX_DiscardUnknown 

func (m *PubSubListPeersResponse_Peer) XXX_DiscardUnknown()

func (*PubSubListPeersResponse_Peer) XXX_Marshal 

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

func (*PubSubListPeersResponse_Peer) XXX_Merge 

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

func (*PubSubListPeersResponse_Peer) XXX_Size 

func (m *PubSubListPeersResponse_Peer) XXX_Size() int

func (*PubSubListPeersResponse_Peer) XXX_Unmarshal 

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

type PubSubMessageResponse 

type PubSubMessageResponse 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"`
}

PubSubMessageResposne is a received pubsub message sent as a response to a subscription rpc call

func (*PubSubMessageResponse) Descriptor 

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

func (*PubSubMessageResponse) GetData 

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

func (*PubSubMessageResponse) GetFrom 

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

func (*PubSubMessageResponse) GetKey 

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

func (*PubSubMessageResponse) GetSeqno 

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

func (*PubSubMessageResponse) GetSignature 

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

func (*PubSubMessageResponse) GetTopicIDs 

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

func (*PubSubMessageResponse) Marshal 

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

func (*PubSubMessageResponse) MarshalTo 

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

func (*PubSubMessageResponse) MarshalToSizedBuffer 

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

func (*PubSubMessageResponse) ProtoMessage 

func (*PubSubMessageResponse) ProtoMessage()

func (*PubSubMessageResponse) Reset 

func (m *PubSubMessageResponse) Reset()

func (*PubSubMessageResponse) Size 

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

func (*PubSubMessageResponse) String 

func (m *PubSubMessageResponse) String() string

func (*PubSubMessageResponse) Unmarshal 

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

func (*PubSubMessageResponse) XXX_DiscardUnknown 

func (m *PubSubMessageResponse) XXX_DiscardUnknown()

func (*PubSubMessageResponse) XXX_Marshal 

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

func (*PubSubMessageResponse) XXX_Merge 

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

func (*PubSubMessageResponse) XXX_Size 

func (m *PubSubMessageResponse) XXX_Size() int

func (*PubSubMessageResponse) XXX_Unmarshal 

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

type PubSubPublishRequest 

type PubSubPublishRequest struct {
	// the topic we are publishing too
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// the data we are publishing
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// whether or not we should engage in advertise operations
	Advertise bool `protobuf:"varint,3,opt,name=advertise,proto3" json:"advertise,omitempty"`
}

PubSubPublishRequest is a message used to publish data to a topic

func (*PubSubPublishRequest) Descriptor 

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

func (*PubSubPublishRequest) GetAdvertise 

func (m *PubSubPublishRequest) GetAdvertise() bool

func (*PubSubPublishRequest) GetData 

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

func (*PubSubPublishRequest) GetTopic 

func (m *PubSubPublishRequest) GetTopic() string

func (*PubSubPublishRequest) Marshal 

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

func (*PubSubPublishRequest) MarshalTo 

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

func (*PubSubPublishRequest) MarshalToSizedBuffer 

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

func (*PubSubPublishRequest) ProtoMessage 

func (*PubSubPublishRequest) ProtoMessage()

func (*PubSubPublishRequest) Reset 

func (m *PubSubPublishRequest) Reset()

func (*PubSubPublishRequest) Size 

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

func (*PubSubPublishRequest) String 

func (m *PubSubPublishRequest) String() string

func (*PubSubPublishRequest) Unmarshal 

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

func (*PubSubPublishRequest) XXX_DiscardUnknown 

func (m *PubSubPublishRequest) XXX_DiscardUnknown()

func (*PubSubPublishRequest) XXX_Marshal 

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

func (*PubSubPublishRequest) XXX_Merge 

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

func (*PubSubPublishRequest) XXX_Size 

func (m *PubSubPublishRequest) XXX_Size() int

func (*PubSubPublishRequest) XXX_Unmarshal 

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

type PubSubSubscribeRequest 

type PubSubSubscribeRequest struct {
	// the topic we should subscribe to
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// indicates whether the server should
	// perform service discover for peers on the same topic
	Discover bool `protobuf:"varint,2,opt,name=discover,proto3" json:"discover,omitempty"`
}

PubSubSubscribeRequest is used to initiate a subscription to a given pubsub topic and stream received messages

func (*PubSubSubscribeRequest) Descriptor 

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

func (*PubSubSubscribeRequest) GetDiscover 

func (m *PubSubSubscribeRequest) GetDiscover() bool

func (*PubSubSubscribeRequest) GetTopic 

func (m *PubSubSubscribeRequest) GetTopic() string

func (*PubSubSubscribeRequest) Marshal 

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

func (*PubSubSubscribeRequest) MarshalTo 

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

func (*PubSubSubscribeRequest) MarshalToSizedBuffer 

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

func (*PubSubSubscribeRequest) ProtoMessage 

func (*PubSubSubscribeRequest) ProtoMessage()

func (*PubSubSubscribeRequest) Reset 

func (m *PubSubSubscribeRequest) Reset()

func (*PubSubSubscribeRequest) Size 

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

func (*PubSubSubscribeRequest) String 

func (m *PubSubSubscribeRequest) String() string

func (*PubSubSubscribeRequest) Unmarshal 

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

func (*PubSubSubscribeRequest) XXX_DiscardUnknown 

func (m *PubSubSubscribeRequest) XXX_DiscardUnknown()

func (*PubSubSubscribeRequest) XXX_Marshal 

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

func (*PubSubSubscribeRequest) XXX_Merge 

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

func (*PubSubSubscribeRequest) XXX_Size 

func (m *PubSubSubscribeRequest) XXX_Size() int

func (*PubSubSubscribeRequest) XXX_Unmarshal 

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

type PubSubTopicsResponse 

type PubSubTopicsResponse struct {
	// the names of topics
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
}

PubSubTopics is a response that returns the names of all known topics

func (*PubSubTopicsResponse) Descriptor 

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

func (*PubSubTopicsResponse) GetNames 

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

func (*PubSubTopicsResponse) Marshal 

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

func (*PubSubTopicsResponse) MarshalTo 

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

func (*PubSubTopicsResponse) MarshalToSizedBuffer 

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

func (*PubSubTopicsResponse) ProtoMessage 

func (*PubSubTopicsResponse) ProtoMessage()

func (*PubSubTopicsResponse) Reset 

func (m *PubSubTopicsResponse) Reset()

func (*PubSubTopicsResponse) Size 

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

func (*PubSubTopicsResponse) String 

func (m *PubSubTopicsResponse) String() string

func (*PubSubTopicsResponse) Unmarshal 

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

func (*PubSubTopicsResponse) XXX_DiscardUnknown 

func (m *PubSubTopicsResponse) XXX_DiscardUnknown()

func (*PubSubTopicsResponse) XXX_Marshal 

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

func (*PubSubTopicsResponse) XXX_Merge 

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

func (*PubSubTopicsResponse) XXX_Size 

func (m *PubSubTopicsResponse) XXX_Size() int

func (*PubSubTopicsResponse) XXX_Unmarshal 

func (m *PubSubTopicsResponse) 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) MarshalTo 

func (m *PutResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *RefCountRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *RefCountResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StatusResponse) MarshalTo(dAtA []byte) (int, 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) Blockstore 

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

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 UnimplementedDagAPIServer 

type UnimplementedDagAPIServer struct {
}

UnimplementedDagAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedDagAPIServer) AddLinksToNode 

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

func (*UnimplementedDagAPIServer) DagGet 

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

func (*UnimplementedDagAPIServer) DagPut 

func (*UnimplementedDagAPIServer) DagPut(ctx context.Context, req *DagPutRequest) (*DagPutResponse, error)
func (*UnimplementedDagAPIServer) GetLinks(ctx context.Context, req *GetLinksRequest) (*GetLinksResponse, error)

func (*UnimplementedDagAPIServer) NewIPLDNode 

func (*UnimplementedDagAPIServer) NewIPLDNode(ctx context.Context, req *NewIPLDNodeRequest) (*DagPutResponse, 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) KeystoreDelete 

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

func (*UnimplementedKeystoreAPIServer) KeystoreGet 

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

func (*UnimplementedKeystoreAPIServer) KeystoreHas 

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

func (*UnimplementedKeystoreAPIServer) KeystoreList 

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

func (*UnimplementedKeystoreAPIServer) KeystorePut 

func (*UnimplementedKeystoreAPIServer) KeystorePut(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) Connect 

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

func (*UnimplementedNodeAPIServer) DisableExtras 

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

func (*UnimplementedNodeAPIServer) Disconnect 

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

func (*UnimplementedNodeAPIServer) EnableExtras 

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

func (*UnimplementedNodeAPIServer) GetPeers 

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

func (*UnimplementedNodeAPIServer) IsConnected 

func (*UnimplementedNodeAPIServer) IsConnected(ctx context.Context, req *IsConnectedRequest) (*IsConnectedResponse, 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) PubSubGetTopics 

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

func (*UnimplementedPubSubAPIServer) PubSubListPeers 

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

func (*UnimplementedPubSubAPIServer) PubSubPublish 

func (*UnimplementedPubSubAPIServer) PubSubPublish(srv PubSubAPI_PubSubPublishServer) error

func (*UnimplementedPubSubAPIServer) PubSubSubscribe 

func (*UnimplementedPubSubAPIServer) PubSubSubscribe(req *PubSubSubscribeRequest, srv PubSubAPI_PubSubSubscribeServer) 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) MarshalTo 

func (m *UploadOptions) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *UploadRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *VersionResponse) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.