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 (*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 (*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 (*DisconnectResponse_StatusMessage) Size

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

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

func (*UnimplementedAdminAPIServer) RefCount

type UnimplementedDagAPIServer

type UnimplementedDagAPIServer struct {
}

UnimplementedDagAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedDagAPIServer) AddLinksToNode

func (*UnimplementedDagAPIServer) DagGet

func (*UnimplementedDagAPIServer) DagPut

func (*UnimplementedDagAPIServer) NewIPLDNode

type UnimplementedFileAPIServer

type UnimplementedFileAPIServer struct {
}

UnimplementedFileAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedFileAPIServer) DownloadFile

func (*UnimplementedFileAPIServer) UploadFile

type UnimplementedKeystoreAPIServer

type UnimplementedKeystoreAPIServer struct {
}

UnimplementedKeystoreAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeystoreAPIServer) KeystoreDelete

func (*UnimplementedKeystoreAPIServer) KeystoreGet

func (*UnimplementedKeystoreAPIServer) KeystoreHas

func (*UnimplementedKeystoreAPIServer) KeystoreList

func (*UnimplementedKeystoreAPIServer) KeystorePut

type UnimplementedNameSysAPIServer

type UnimplementedNameSysAPIServer struct {
}

UnimplementedNameSysAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedNameSysAPIServer) NameSysPublish

func (*UnimplementedNameSysAPIServer) NameSysResolve

func (*UnimplementedNameSysAPIServer) NameSysResolveAsync

type UnimplementedNodeAPIServer

type UnimplementedNodeAPIServer struct {
}

UnimplementedNodeAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeAPIServer) Connect

func (*UnimplementedNodeAPIServer) DisableExtras

func (*UnimplementedNodeAPIServer) Disconnect

func (*UnimplementedNodeAPIServer) EnableExtras

func (*UnimplementedNodeAPIServer) GetPeers

func (*UnimplementedNodeAPIServer) IsConnected

func (*UnimplementedNodeAPIServer) P2P

type UnimplementedPubSubAPIServer

type UnimplementedPubSubAPIServer struct {
}

UnimplementedPubSubAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedPubSubAPIServer) PubSubGetTopics

func (*UnimplementedPubSubAPIServer) PubSubListPeers

func (*UnimplementedPubSubAPIServer) PubSubPublish

func (*UnimplementedPubSubAPIServer) PubSubSubscribe

type UnimplementedStatusAPIServer

type UnimplementedStatusAPIServer struct {
}

UnimplementedStatusAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedStatusAPIServer) Status

func (*UnimplementedStatusAPIServer) Version

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

Jump to

Keyboard shortcuts

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