pb

package
v3.0.0-rc8 Latest Latest
Warning

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

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

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 (
	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 (
	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 CONNMGMTREQTYPE_name = map[int32]string{
	0: "CM_CONNECT",
	1: "CM_DISCONNECT",
	2: "CM_STATUS",
	3: "CM_GET_PEERS",
}
View Source 
var CONNMGMTREQTYPE_value = map[string]int32{
	"CM_CONNECT":    0,
	"CM_DISCONNECT": 1,
	"CM_STATUS":     2,
	"CM_GET_PEERS":  3,
}
View Source 
var DAGREQTYPE_name = map[int32]string{
	0: "DAG_PUT",
	1: "DAG_GET",
	2: "DAG_NEW_NODE",
	3: "DAG_ADD_LINKS",
	4: "DAG_GET_LINKS",
}
View Source 
var DAGREQTYPE_value = map[string]int32{
	"DAG_PUT":       0,
	"DAG_GET":       1,
	"DAG_NEW_NODE":  2,
	"DAG_ADD_LINKS": 3,
	"DAG_GET_LINKS": 4,
}
View Source 
var EXTRASREQTYPE_name = map[int32]string{
	0: "EX_ENABLE",
	1: "EX_DISABLE",
}
View Source 
var EXTRASREQTYPE_value = map[string]int32{
	"EX_ENABLE":  0,
	"EX_DISABLE": 1,
}
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 KSREQTYPE_name = map[int32]string{
	0: "KS_HAS",
	1: "KS_GET",
	2: "KS_PUT",
	3: "KS_DELETE",
	4: "KS_LIST",
}
View Source 
var KSREQTYPE_value = map[string]int32{
	"KS_HAS":    0,
	"KS_GET":    1,
	"KS_PUT":    2,
	"KS_DELETE": 3,
	"KS_LIST":   4,
}
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 PSREQTYPE_name = map[int32]string{
	0: "PS_GET_TOPICS",
	1: "PS_LIST_PEERS",
	2: "PS_SUBSCRIBE",
	3: "PS_PUBLISH",
}
View Source 
var PSREQTYPE_value = map[string]int32{
	"PS_GET_TOPICS": 0,
	"PS_LIST_PEERS": 1,
	"PS_SUBSCRIBE":  2,
	"PS_PUBLISH":    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 RegisterFileAPIServer 

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

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 AdminAPIClient 

type AdminAPIClient interface {
	// ManageGC is used to manage TemporalX's garbage collection process
	ManageGC(ctx context.Context, in *ManageGCRequest, opts ...grpc.CallOption) (*ManageGCResponse, error)
	// RefCount is used to analyze the counter store and pull reference count information
	RefCount(ctx context.Context, in *RefCountRequest, opts ...grpc.CallOption) (*RefCountResponse, error)
}

AdminAPIClient is the client API for AdminAPI service.

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

func NewAdminAPIClient 

func NewAdminAPIClient(cc *grpc.ClientConn) AdminAPIClient

type AdminAPIServer 

type AdminAPIServer interface {
	// ManageGC is used to manage TemporalX's garbage collection process
	ManageGC(context.Context, *ManageGCRequest) (*ManageGCResponse, error)
	// RefCount is used to analyze the counter store and pull reference count information
	RefCount(context.Context, *RefCountRequest) (*RefCountResponse, error)
}

AdminAPIServer is the server API for AdminAPI service.

type BSREQOPTS 

type BSREQOPTS int32

BSREQOPTS are options for blockstore requests 

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

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 {
	//  indicates the particular request type being made
	RequestType BSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.BSREQTYPE" json:"requestType,omitempty"`
	// optional request settings
	ReqOpts []BSREQOPTS `protobuf:"varint,2,rep,packed,name=reqOpts,proto3,enum=pb.BSREQOPTS" json:"reqOpts,omitempty"`
	// cids of blocks
	// sent by: BS_DELETE, BS_GET, BS_GET_MANY
	Cids []string `protobuf:"bytes,3,rep,name=cids,proto3" json:"cids,omitempty"`
	// the data we are putting
	// sent by: BS_PUT, BS_PUT_MANY
	Data [][]byte `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
	// the cid version to use when constructing blocks, default is v1
	// sent by: BS_PUT, BS_PUT_MANY
	CidVersion string `protobuf:"bytes,5,opt,name=cidVersion,proto3" json:"cidVersion,omitempty"`
	// the hash function to use when constructing blocks, default is sha2-256
	// sent by: BS_PUT, BS_PUT_MANY
	HashFunc string `protobuf:"bytes,7,opt,name=hashFunc,proto3" json:"hashFunc,omitempty"`
}

BlockstoreRequest is a message used to control blockstores

func (*BlockstoreRequest) Descriptor 

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

func (*BlockstoreRequest) GetCidVersion 

func (m *BlockstoreRequest) GetCidVersion() string

func (*BlockstoreRequest) GetCids 

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

func (*BlockstoreRequest) GetData 

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

func (*BlockstoreRequest) GetHashFunc 

func (m *BlockstoreRequest) GetHashFunc() string

func (*BlockstoreRequest) GetReqOpts 

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

func (*BlockstoreRequest) GetRequestType 

func (m *BlockstoreRequest) GetRequestType() BSREQTYPE

func (*BlockstoreRequest) Marshal 

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

func (*BlockstoreRequest) MarshalTo 

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

func (*BlockstoreRequest) MarshalToSizedBuffer 

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

func (*BlockstoreRequest) ProtoMessage 

func (*BlockstoreRequest) ProtoMessage()

func (*BlockstoreRequest) Reset 

func (m *BlockstoreRequest) Reset()

func (*BlockstoreRequest) Size 

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

func (*BlockstoreRequest) String 

func (m *BlockstoreRequest) String() string

func (*BlockstoreRequest) Unmarshal 

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

func (*BlockstoreRequest) XXX_DiscardUnknown 

func (m *BlockstoreRequest) XXX_DiscardUnknown()

func (*BlockstoreRequest) XXX_Marshal 

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

func (*BlockstoreRequest) XXX_Merge 

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

func (*BlockstoreRequest) XXX_Size 

func (m *BlockstoreRequest) XXX_Size() int

func (*BlockstoreRequest) XXX_Unmarshal 

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

type BlockstoreResponse 

type BlockstoreResponse struct {
	// indicates the particular request type being made
	RequestType BSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.BSREQTYPE" json:"requestType,omitempty"`
	// a copy of blocks from the blockstore
	// sent by: BS_PUT, BS_PUT_MANY, BS_GET, BS_GET_MANY
	// in the case of BS_PUT, and BS_PUT_MANY requests
	// the data field will be empty as this is only populated
	// by get requests
	Blocks []*Block `protobuf:"bytes,2,rep,name=blocks,proto3" json:"blocks,omitempty"`
}

BlockstoreResponse is a response to a BlockstoreqRequest

func (*BlockstoreResponse) Descriptor 

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

func (*BlockstoreResponse) GetBlocks 

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

func (*BlockstoreResponse) GetRequestType 

func (m *BlockstoreResponse) GetRequestType() BSREQTYPE

func (*BlockstoreResponse) Marshal 

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

func (*BlockstoreResponse) MarshalTo 

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

func (*BlockstoreResponse) MarshalToSizedBuffer 

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

func (*BlockstoreResponse) ProtoMessage 

func (*BlockstoreResponse) ProtoMessage()

func (*BlockstoreResponse) Reset 

func (m *BlockstoreResponse) Reset()

func (*BlockstoreResponse) Size 

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

func (*BlockstoreResponse) String 

func (m *BlockstoreResponse) String() string

func (*BlockstoreResponse) Unmarshal 

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

func (*BlockstoreResponse) XXX_DiscardUnknown 

func (m *BlockstoreResponse) XXX_DiscardUnknown()

func (*BlockstoreResponse) XXX_Marshal 

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

func (*BlockstoreResponse) XXX_Merge 

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

func (*BlockstoreResponse) XXX_Size 

func (m *BlockstoreResponse) XXX_Size() int

func (*BlockstoreResponse) XXX_Unmarshal 

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

type CONNMGMTREQTYPE 

type CONNMGMTREQTYPE int32

CONNMGMTREQTYPE indicates the particular ConnMgmt request being performed 

const (
	// CM_CONNECT is used to connect to a libp2p peer
	CONNMGMTREQTYPE_CM_CONNECT CONNMGMTREQTYPE = 0
	// CM_DISCONNECT is used to disconnect from a libp2p peer
	CONNMGMTREQTYPE_CM_DISCONNECT CONNMGMTREQTYPE = 1
	// CM_STATUS is used to return status information about libp2p peer connections
	// useful for determining whether or not we are connected to someone
	CONNMGMTREQTYPE_CM_STATUS CONNMGMTREQTYPE = 2
	//CM_GET_PEERS is used to return all known peers
	CONNMGMTREQTYPE_CM_GET_PEERS CONNMGMTREQTYPE = 3
)

func (CONNMGMTREQTYPE) EnumDescriptor 

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

func (CONNMGMTREQTYPE) String 

func (x CONNMGMTREQTYPE) String() string

type ConnMgmtRequest 

type ConnMgmtRequest struct {
	// indicates the particular connection management request being performed
	RequestType CONNMGMTREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.CONNMGMTREQTYPE" json:"requestType,omitempty"`
	// a list of multiaddrs
	// sent by: CM_CONNECT
	MultiAddrs []string `protobuf:"bytes,2,rep,name=multiAddrs,proto3" json:"multiAddrs,omitempty"`
	// a list of peer IDs
	// sent by: CM_DISCONNECT, CM_STATUS, CM_GET_PEERS
	PeerIDs []string `protobuf:"bytes,3,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"`
}

func (*ConnMgmtRequest) Descriptor 

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

func (*ConnMgmtRequest) GetMultiAddrs 

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

func (*ConnMgmtRequest) GetPeerIDs 

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

func (*ConnMgmtRequest) GetRequestType 

func (m *ConnMgmtRequest) GetRequestType() CONNMGMTREQTYPE

func (*ConnMgmtRequest) Marshal 

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

func (*ConnMgmtRequest) MarshalTo 

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

func (*ConnMgmtRequest) MarshalToSizedBuffer 

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

func (*ConnMgmtRequest) ProtoMessage 

func (*ConnMgmtRequest) ProtoMessage()

func (*ConnMgmtRequest) Reset 

func (m *ConnMgmtRequest) Reset()

func (*ConnMgmtRequest) Size 

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

func (*ConnMgmtRequest) String 

func (m *ConnMgmtRequest) String() string

func (*ConnMgmtRequest) Unmarshal 

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

func (*ConnMgmtRequest) XXX_DiscardUnknown 

func (m *ConnMgmtRequest) XXX_DiscardUnknown()

func (*ConnMgmtRequest) XXX_Marshal 

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

func (*ConnMgmtRequest) XXX_Merge 

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

func (*ConnMgmtRequest) XXX_Size 

func (m *ConnMgmtRequest) XXX_Size() int

func (*ConnMgmtRequest) XXX_Unmarshal 

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

type ConnMgmtResponse 

type ConnMgmtResponse struct {
	// indicates the particular connection management request being performed
	RequestType CONNMGMTREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.CONNMGMTREQTYPE" json:"requestType,omitempty"`
	Connected   map[string]bool `` /* 160-byte string literal not displayed */
	// a map of the peer id, and a custom message indicating success, or why there was a failure
	Status  map[string]*ConnMgmtStatus `` /* 153-byte string literal not displayed */
	PeerIDs []string                   `protobuf:"bytes,4,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"`
}

func (*ConnMgmtResponse) Descriptor 

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

func (*ConnMgmtResponse) GetConnected 

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

func (*ConnMgmtResponse) GetPeerIDs 

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

func (*ConnMgmtResponse) GetRequestType 

func (m *ConnMgmtResponse) GetRequestType() CONNMGMTREQTYPE

func (*ConnMgmtResponse) GetStatus 

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

func (*ConnMgmtResponse) Marshal 

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

func (*ConnMgmtResponse) MarshalTo 

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

func (*ConnMgmtResponse) MarshalToSizedBuffer 

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

func (*ConnMgmtResponse) ProtoMessage 

func (*ConnMgmtResponse) ProtoMessage()

func (*ConnMgmtResponse) Reset 

func (m *ConnMgmtResponse) Reset()

func (*ConnMgmtResponse) Size 

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

func (*ConnMgmtResponse) String 

func (m *ConnMgmtResponse) String() string

func (*ConnMgmtResponse) Unmarshal 

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

func (*ConnMgmtResponse) XXX_DiscardUnknown 

func (m *ConnMgmtResponse) XXX_DiscardUnknown()

func (*ConnMgmtResponse) XXX_Marshal 

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

func (*ConnMgmtResponse) XXX_Merge 

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

func (*ConnMgmtResponse) XXX_Size 

func (m *ConnMgmtResponse) XXX_Size() int

func (*ConnMgmtResponse) XXX_Unmarshal 

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

type ConnMgmtStatus 

type ConnMgmtStatus struct {
	// indicate whether or not we actually disconnected
	Disconnected bool `protobuf:"varint,1,opt,name=disconnected,proto3" json:"disconnected,omitempty"`
	// if disconnected is false, the reason why it is false
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

Contains status information about a particular disconnect attempt

func (*ConnMgmtStatus) Descriptor 

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

func (*ConnMgmtStatus) GetDisconnected 

func (m *ConnMgmtStatus) GetDisconnected() bool

func (*ConnMgmtStatus) GetReason 

func (m *ConnMgmtStatus) GetReason() string

func (*ConnMgmtStatus) Marshal 

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

func (*ConnMgmtStatus) MarshalTo 

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

func (*ConnMgmtStatus) MarshalToSizedBuffer 

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

func (*ConnMgmtStatus) ProtoMessage 

func (*ConnMgmtStatus) ProtoMessage()

func (*ConnMgmtStatus) Reset 

func (m *ConnMgmtStatus) Reset()

func (*ConnMgmtStatus) Size 

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

func (*ConnMgmtStatus) String 

func (m *ConnMgmtStatus) String() string

func (*ConnMgmtStatus) Unmarshal 

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

func (*ConnMgmtStatus) XXX_DiscardUnknown 

func (m *ConnMgmtStatus) XXX_DiscardUnknown()

func (*ConnMgmtStatus) XXX_Marshal 

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

func (*ConnMgmtStatus) XXX_Merge 

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

func (*ConnMgmtStatus) XXX_Size 

func (m *ConnMgmtStatus) XXX_Size() int

func (*ConnMgmtStatus) XXX_Unmarshal 

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

type DAGREQTYPE 

type DAGREQTYPE int32

DAGREQTYPE indicates the particular DagAPI request being performed 

const (
	// DAG_PUT is used to add new IPLD objects
	DAGREQTYPE_DAG_PUT DAGREQTYPE = 0
	// DAG_GET is used to retrieve IPLD object data
	DAGREQTYPE_DAG_GET DAGREQTYPE = 1
	// DAG_NEW_NODE is used to create a new IPLD node object
	DAGREQTYPE_DAG_NEW_NODE DAGREQTYPE = 2
	// DAG_ADD_LINKS is used to add links to an IPLD node object
	DAGREQTYPE_DAG_ADD_LINKS DAGREQTYPE = 3
	// DAG_GET_LINKS is used to retrieve all links contained in an IPLD node object
	DAGREQTYPE_DAG_GET_LINKS DAGREQTYPE = 4
)

func (DAGREQTYPE) EnumDescriptor 

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

func (DAGREQTYPE) String 

func (x DAGREQTYPE) String() string

type DagRequest 

type DagRequest struct {
	// indicates the request being performed
	// sent by: all request types
	RequestType DAGREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.DAGREQTYPE" json:"requestType,omitempty"`
	// data that we will be storing
	// sent by: DAG_PUT, DAG_NEW_NODE
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// the object encoding type (raw, cbor, protobuf, etc...)
	// sent by: DAG_PUT
	ObjectEncoding string `protobuf:"bytes,3,opt,name=objectEncoding,proto3" json:"objectEncoding,omitempty"`
	// the serialization format (raw, cbor, protobuf, etc...)
	// sent by: DAG_PUT
	SerializationFormat string `protobuf:"bytes,4,opt,name=serializationFormat,proto3" json:"serializationFormat,omitempty"`
	// the hash function to to use (sha2-256, sha3-512, etc...)
	// sent by: DAG_PUT, DAG_NEW_NODE, DAG_ADD_LINKS
	HashFunc string `protobuf:"bytes,5,opt,name=hashFunc,proto3" json:"hashFunc,omitempty"`
	// the cid version to use (0, 1)
	// sent by: DAG_PUT, DAG_NEW_NODE
	CidVersion int64 `protobuf:"varint,6,opt,name=cidVersion,proto3" json:"cidVersion,omitempty"`
	// the hash of the object we are processing
	// sent by: DAG_GET, DAG_NEW_NODe, DAG_ADD_LINKS, DAG_GET_LINKS
	Hash string `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
	// indicates links and their names. key = name, value = link hash
	// sent by: DAG_NEW_NODE, DAG_ADD_LINKS
	Links map[string]string `` /* 151-byte string literal not displayed */
}

Used to submit a request to Dag or DagStream RPCs

func (*DagRequest) Descriptor 

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

func (*DagRequest) GetCidVersion 

func (m *DagRequest) GetCidVersion() int64

func (*DagRequest) GetData 

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

func (*DagRequest) GetHash 

func (m *DagRequest) GetHash() string

func (*DagRequest) GetHashFunc 

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

func (*DagRequest) GetObjectEncoding 

func (m *DagRequest) GetObjectEncoding() string

func (*DagRequest) GetRequestType 

func (m *DagRequest) GetRequestType() DAGREQTYPE

func (*DagRequest) GetSerializationFormat 

func (m *DagRequest) GetSerializationFormat() string

func (*DagRequest) Marshal 

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

func (*DagRequest) MarshalTo 

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

func (*DagRequest) MarshalToSizedBuffer 

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

func (*DagRequest) ProtoMessage 

func (*DagRequest) ProtoMessage()

func (*DagRequest) Reset 

func (m *DagRequest) Reset()

func (*DagRequest) Size 

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

func (*DagRequest) String 

func (m *DagRequest) String() string

func (*DagRequest) Unmarshal 

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

func (*DagRequest) XXX_DiscardUnknown 

func (m *DagRequest) XXX_DiscardUnknown()

func (*DagRequest) XXX_Marshal 

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

func (*DagRequest) XXX_Merge 

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

func (*DagRequest) XXX_Size 

func (m *DagRequest) XXX_Size() int

func (*DagRequest) XXX_Unmarshal 

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

type DagResponse 

type DagResponse struct {
	// indicates the request being performed
	// sent by: all request types
	RequestType DAGREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.DAGREQTYPE" json:"requestType,omitempty"`
	// returns the hashes of newly generated IPLD objects
	// sent by: DAG_PUT, DAG_NEW_NODE, DAG_ADD_LINKS, DAG_GET_LINKS
	Hashes []string `protobuf:"bytes,2,rep,name=hashes,proto3" json:"hashes,omitempty"`
	// the actual data contained by the IPLD object
	// sent by: DAG_GET
	RawData []byte `protobuf:"bytes,3,opt,name=rawData,proto3" json:"rawData,omitempty"`
	// the links contained within an IPLD node object
	// sent by: DAG_GET_LINKS
	Links []*IPLDLink `protobuf:"bytes,4,rep,name=links,proto3" json:"links,omitempty"`
}

Used in response to a Dag or DagStream RPC

func (*DagResponse) Descriptor 

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

func (*DagResponse) GetHashes 

func (m *DagResponse) GetHashes() []string
func (m *DagResponse) GetLinks() []*IPLDLink

func (*DagResponse) GetRawData 

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

func (*DagResponse) GetRequestType 

func (m *DagResponse) GetRequestType() DAGREQTYPE

func (*DagResponse) Marshal 

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

func (*DagResponse) MarshalTo 

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

func (*DagResponse) MarshalToSizedBuffer 

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

func (*DagResponse) ProtoMessage 

func (*DagResponse) ProtoMessage()

func (*DagResponse) Reset 

func (m *DagResponse) Reset()

func (*DagResponse) Size 

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

func (*DagResponse) String 

func (m *DagResponse) String() string

func (*DagResponse) Unmarshal 

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

func (*DagResponse) XXX_DiscardUnknown 

func (m *DagResponse) XXX_DiscardUnknown()

func (*DagResponse) XXX_Marshal 

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

func (*DagResponse) XXX_Merge 

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

func (*DagResponse) XXX_Size 

func (m *DagResponse) XXX_Size() int

func (*DagResponse) XXX_Unmarshal 

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

type DownloadRequest 

type DownloadRequest struct {
	// hash is the ipfs hash/cid (content identifier) of the data to download
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// chunkSize specifies the size of chunks to be sent to the client
	// it allows us to efficiently control incoming data amounts which
	// is useful on machines with low-memory
	ChunkSize int32 `protobuf:"varint,2,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
}

DownloadRequest is used to download a UnixFS object although it can in theory be used with other type of objects there may be some undefined behavior

func (*DownloadRequest) Descriptor 

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

func (*DownloadRequest) GetChunkSize 

func (m *DownloadRequest) GetChunkSize() int32

func (*DownloadRequest) GetHash 

func (m *DownloadRequest) GetHash() string

func (*DownloadRequest) Marshal 

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

func (*DownloadRequest) 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 EXTRASREQTYPE 

type EXTRASREQTYPE int32

EXTRASREQTYPE indicates the particular Extras request being performed 

const (
	// EX_ENABLE is used to enable a particular node extras feature
	EXTRASREQTYPE_EX_ENABLE EXTRASREQTYPE = 0
	// EX_DISABLE is used to disable a particular node extras feature
	EXTRASREQTYPE_EX_DISABLE EXTRASREQTYPE = 1
)

func (EXTRASREQTYPE) EnumDescriptor 

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

func (EXTRASREQTYPE) String 

func (x EXTRASREQTYPE) String() string

type EXTRASTYPE 

type EXTRASTYPE int32

EXTRASTYPE denotes a particular extras type 

const (
	// IDENTIFY is the identify service
	EXTRASTYPE_IDENTIFY EXTRASTYPE = 0
	// PUBSUB is the libp2p pubsub system
	EXTRASTYPE_PUBSUB EXTRASTYPE = 1
	// DISCOVERY is a libp2p discovery service
	EXTRASTYPE_DISCOVERY EXTRASTYPE = 2
	// MDNS is used to discover libp2p hosts over mdns
	EXTRASTYPE_MDNS EXTRASTYPE = 3
)

func (EXTRASTYPE) EnumDescriptor 

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

func (EXTRASTYPE) String 

func (x EXTRASTYPE) String() string

type Empty 

type Empty struct {
}

Empty is an empty message

func (*Empty) Descriptor 

func (*Empty) 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 ExtrasRequest 

type ExtrasRequest struct {
	// indicates the request being performed
	RequestType EXTRASREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.EXTRASREQTYPE" json:"requestType,omitempty"`
	// indicates the extras feature this request applies to
	ExtrasFeature EXTRASTYPE `protobuf:"varint,2,opt,name=extrasFeature,proto3,enum=pb.EXTRASTYPE" json:"extrasFeature,omitempty"`
}

func (*ExtrasRequest) Descriptor 

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

func (*ExtrasRequest) GetExtrasFeature 

func (m *ExtrasRequest) GetExtrasFeature() EXTRASTYPE

func (*ExtrasRequest) GetRequestType 

func (m *ExtrasRequest) GetRequestType() EXTRASREQTYPE

func (*ExtrasRequest) Marshal 

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

func (*ExtrasRequest) MarshalTo 

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

func (*ExtrasRequest) MarshalToSizedBuffer 

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

func (*ExtrasRequest) ProtoMessage 

func (*ExtrasRequest) ProtoMessage()

func (*ExtrasRequest) Reset 

func (m *ExtrasRequest) Reset()

func (*ExtrasRequest) Size 

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

func (*ExtrasRequest) String 

func (m *ExtrasRequest) String() string

func (*ExtrasRequest) Unmarshal 

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

func (*ExtrasRequest) XXX_DiscardUnknown 

func (m *ExtrasRequest) XXX_DiscardUnknown()

func (*ExtrasRequest) XXX_Marshal 

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

func (*ExtrasRequest) XXX_Merge 

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

func (*ExtrasRequest) XXX_Size 

func (m *ExtrasRequest) XXX_Size() int

func (*ExtrasRequest) XXX_Unmarshal 

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

type FileAPIClient 

type FileAPIClient interface {
	// UploadFile allows uploading a file as a UnixFS object (equivalent to ipfs add)
	UploadFile(ctx context.Context, opts ...grpc.CallOption) (FileAPI_UploadFileClient, error)
	// DownloadFile allows downloading a UnixFS object (equivalent to ipfs get)
	DownloadFile(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (FileAPI_DownloadFileClient, error)
}

FileAPIClient is the client API for FileAPI service.

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

func NewFileAPIClient 

func NewFileAPIClient(cc *grpc.ClientConn) FileAPIClient

type FileAPIServer 

type FileAPIServer interface {
	// UploadFile allows uploading a file as a UnixFS object (equivalent to ipfs add)
	UploadFile(FileAPI_UploadFileServer) error
	// DownloadFile allows downloading a UnixFS object (equivalent to ipfs get)
	DownloadFile(*DownloadRequest, FileAPI_DownloadFileServer) error
}

FileAPIServer is the server API for FileAPI service.

type FileAPI_DownloadFileClient 

type FileAPI_DownloadFileClient interface {
	Recv() (*DownloadResponse, error)
	grpc.ClientStream
}

type FileAPI_DownloadFileServer 

type FileAPI_DownloadFileServer interface {
	Send(*DownloadResponse) error
	grpc.ServerStream
}

type FileAPI_UploadFileClient 

type FileAPI_UploadFileClient interface {
	Send(*UploadRequest) error
	CloseAndRecv() (*PutResponse, error)
	grpc.ClientStream
}

type FileAPI_UploadFileServer 

type FileAPI_UploadFileServer interface {
	SendAndClose(*PutResponse) error
	Recv() (*UploadRequest, error)
	grpc.ServerStream
}

type GCREQTYPE 

type GCREQTYPE int32

GCREQTYPE specifies the type of GC management call being performed 

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 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 KSREQTYPE 

type KSREQTYPE int32

KSREQTYPE indicates the particular KeystoreAPI request being performed 

const (
	// KS_HAS is used to check if the key exists in our keystore
	KSREQTYPE_KS_HAS KSREQTYPE = 0
	// KS_GET is used to retrieve private key bytes from our keystore
	KSREQTYPE_KS_GET KSREQTYPE = 1
	// KS_PUT is used to store private key bytes in our keystore
	KSREQTYPE_KS_PUT KSREQTYPE = 2
	// KS_DELETE is used to delete private keys from our keystore
	KSREQTYPE_KS_DELETE KSREQTYPE = 3
	// KS_LIST is used to list all keys in our keystore by their name
	KSREQTYPE_KS_LIST KSREQTYPE = 4
)

func (KSREQTYPE) EnumDescriptor 

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

func (KSREQTYPE) String 

func (x KSREQTYPE) String() string

type KeystoreRequest 

type KeystoreRequest struct {
	// indicates the request type being performed
	RequestType KSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.KSREQTYPE" json:"requestType,omitempty"`
	// name of the key the request is for
	// sent by: KS_HAS, KS_GET, KS_PUT, KS_DELETE
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// the actual private key bytes
	// sent by: KS_PUT
	PrivateKey []byte `protobuf:"bytes,3,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
}

Used to submit a request to Keystore RPC

func (*KeystoreRequest) Descriptor 

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

func (*KeystoreRequest) GetName 

func (m *KeystoreRequest) GetName() string

func (*KeystoreRequest) GetPrivateKey 

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

func (*KeystoreRequest) GetRequestType 

func (m *KeystoreRequest) GetRequestType() KSREQTYPE

func (*KeystoreRequest) Marshal 

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

func (*KeystoreRequest) 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 {
	// indicates the request type being performed
	RequestType KSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.KSREQTYPE" json:"requestType,omitempty"`
	// the private key bytes
	// sent by: KS_GET
	PrivateKey []byte `protobuf:"bytes,2,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
	// contains all known key names
	// sent by: KS_LIST
	KeyNames []string `protobuf:"bytes,3,rep,name=keyNames,proto3" json:"keyNames,omitempty"`
	// indicates if we have the key in our keystore
	// sent by: KS_HAS
	Has bool `protobuf:"varint,4,opt,name=has,proto3" json:"has,omitempty"`
}

Used in response to a Keystore RPC

func (*KeystoreResponse) Descriptor 

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

func (*KeystoreResponse) GetHas 

func (m *KeystoreResponse) GetHas() bool

func (*KeystoreResponse) GetKeyNames 

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

func (*KeystoreResponse) GetPrivateKey 

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

func (*KeystoreResponse) GetRequestType 

func (m *KeystoreResponse) GetRequestType() KSREQTYPE

func (*KeystoreResponse) Marshal 

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

func (*KeystoreResponse) 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 NodeAPIClient 

type NodeAPIClient interface {
	// ConnMgmt provides control over libp2p connections
	ConnMgmt(ctx context.Context, in *ConnMgmtRequest, opts ...grpc.CallOption) (*ConnMgmtResponse, error)
	// Extras provide control over node extras capabilities
	Extras(ctx context.Context, in *ExtrasRequest, opts ...grpc.CallOption) (*Empty, error)
	// P2P allows control of generalized p2p streams for tcp/udp based protocol.
	// By using this RPC, we can tunnel traffic similar to ssh tunneling
	// except using libp2p as the transport layer, and and tcp/udp port.
	P2P(ctx context.Context, in *P2PRequest, opts ...grpc.CallOption) (*P2PResponse, error)
	// Blockstore allows low-level management of the underlying blockstore
	Blockstore(ctx context.Context, in *BlockstoreRequest, opts ...grpc.CallOption) (*BlockstoreResponse, error)
	// Dag is a unidirectional rpc allowing manipulation of low-level ipld objects
	Dag(ctx context.Context, in *DagRequest, opts ...grpc.CallOption) (*DagResponse, error)
	//Keystore is a unidirectional RPC allowing management of ipfs keystores
	Keystore(ctx context.Context, in *KeystoreRequest, opts ...grpc.CallOption) (*KeystoreResponse, error)
	// Persist is used to retrieve data from the network and make it available locally
	Persist(ctx context.Context, in *PersistRequest, opts ...grpc.CallOption) (*PersistResponse, error)
}

NodeAPIClient is the client API for NodeAPI service.

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

func NewNodeAPIClient 

func NewNodeAPIClient(cc *grpc.ClientConn) NodeAPIClient

type NodeAPIServer 

type NodeAPIServer interface {
	// ConnMgmt provides control over libp2p connections
	ConnMgmt(context.Context, *ConnMgmtRequest) (*ConnMgmtResponse, error)
	// Extras provide control over node extras capabilities
	Extras(context.Context, *ExtrasRequest) (*Empty, error)
	// P2P allows control of generalized p2p streams for tcp/udp based protocol.
	// By using this RPC, we can tunnel traffic similar to ssh tunneling
	// except using libp2p as the transport layer, and and tcp/udp port.
	P2P(context.Context, *P2PRequest) (*P2PResponse, error)
	// Blockstore allows low-level management of the underlying blockstore
	Blockstore(context.Context, *BlockstoreRequest) (*BlockstoreResponse, error)
	// Dag is a unidirectional rpc allowing manipulation of low-level ipld objects
	Dag(context.Context, *DagRequest) (*DagResponse, error)
	//Keystore is a unidirectional RPC allowing management of ipfs keystores
	Keystore(context.Context, *KeystoreRequest) (*KeystoreResponse, error)
	// Persist is used to retrieve data from the network and make it available locally
	Persist(context.Context, *PersistRequest) (*PersistResponse, 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 PSREQTYPE 

type PSREQTYPE int32

PSREQTYPE indicates the particular PubSubAPI request being performed 

const (
	// PS_GET_TOPICS is used to return a list of subscribed pubsub topics
	PSREQTYPE_PS_GET_TOPICS PSREQTYPE = 0
	// PS_LIST_PEERS is used to return a list of peers subscribed to topics we are subscribed to
	PSREQTYPE_PS_LIST_PEERS PSREQTYPE = 1
	// PS_SUBSCRIBE is used to establish a persistent subscription to a pubsub topic
	PSREQTYPE_PS_SUBSCRIBE PSREQTYPE = 2
	// PS_PUBLISH is used to publisbh a message to a pubsub topic
	PSREQTYPE_PS_PUBLISH PSREQTYPE = 3
)

func (PSREQTYPE) EnumDescriptor 

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

func (PSREQTYPE) String 

func (x PSREQTYPE) String() string

type PersistRequest 

type PersistRequest struct {
	// cids to persist locally
	Cids []string `protobuf:"bytes,1,rep,name=cids,proto3" json:"cids,omitempty"`
}

func (*PersistRequest) Descriptor 

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

func (*PersistRequest) GetCids 

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

func (*PersistRequest) Marshal 

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

func (*PersistRequest) MarshalTo 

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

func (*PersistRequest) MarshalToSizedBuffer 

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

func (*PersistRequest) ProtoMessage 

func (*PersistRequest) ProtoMessage()

func (*PersistRequest) Reset 

func (m *PersistRequest) Reset()

func (*PersistRequest) Size 

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

func (*PersistRequest) String 

func (m *PersistRequest) String() string

func (*PersistRequest) Unmarshal 

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

func (*PersistRequest) XXX_DiscardUnknown 

func (m *PersistRequest) XXX_DiscardUnknown()

func (*PersistRequest) XXX_Marshal 

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

func (*PersistRequest) XXX_Merge 

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

func (*PersistRequest) XXX_Size 

func (m *PersistRequest) XXX_Size() int

func (*PersistRequest) XXX_Unmarshal 

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

type PersistResponse 

type PersistResponse struct {
	// key = cid, value = whether or not it was persisted
	Status map[string]bool `` /* 154-byte string literal not displayed */
	// key = cid, value = error if not persisted
	Errors map[string]string `` /* 153-byte string literal not displayed */
}

func (*PersistResponse) Descriptor 

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

func (*PersistResponse) GetErrors 

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

func (*PersistResponse) GetStatus 

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

func (*PersistResponse) Marshal 

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

func (*PersistResponse) MarshalTo 

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

func (*PersistResponse) MarshalToSizedBuffer 

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

func (*PersistResponse) ProtoMessage 

func (*PersistResponse) ProtoMessage()

func (*PersistResponse) Reset 

func (m *PersistResponse) Reset()

func (*PersistResponse) Size 

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

func (*PersistResponse) String 

func (m *PersistResponse) String() string

func (*PersistResponse) Unmarshal 

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

func (*PersistResponse) XXX_DiscardUnknown 

func (m *PersistResponse) XXX_DiscardUnknown()

func (*PersistResponse) XXX_Marshal 

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

func (*PersistResponse) XXX_Merge 

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

func (*PersistResponse) XXX_Size 

func (m *PersistResponse) XXX_Size() int

func (*PersistResponse) XXX_Unmarshal 

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

type PubSubAPIClient 

type PubSubAPIClient interface {
	// PubSub allows controlling libp2p pubsub topics and subscriptions using
	// a bidirectional streaming API
	PubSub(ctx context.Context, opts ...grpc.CallOption) (PubSubAPI_PubSubClient, error)
}

PubSubAPIClient is the client API for PubSubAPI service.

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

func NewPubSubAPIClient 

func NewPubSubAPIClient(cc *grpc.ClientConn) PubSubAPIClient

type PubSubAPIServer 

type PubSubAPIServer interface {
	// PubSub allows controlling libp2p pubsub topics and subscriptions using
	// a bidirectional streaming API
	PubSub(PubSubAPI_PubSubServer) error
}

PubSubAPIServer is the server API for PubSubAPI service.

type PubSubAPI_PubSubClient 

type PubSubAPI_PubSubClient interface {
	Send(*PubSubRequest) error
	Recv() (*PubSubResponse, error)
	grpc.ClientStream
}

type PubSubAPI_PubSubServer 

type PubSubAPI_PubSubServer interface {
	Send(*PubSubResponse) error
	Recv() (*PubSubRequest, error)
	grpc.ServerStream
}

type PubSubMessage 

type PubSubMessage struct {
	// who this message is from
	From []byte `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// the data of this message
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// the sequence number of this message
	Seqno []byte `protobuf:"bytes,3,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// the topic IDs this message is sent to
	TopicIDs []string `protobuf:"bytes,4,rep,name=topicIDs,proto3" json:"topicIDs,omitempty"`
	// the signature of the sender
	Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	// the key of the sender
	Key []byte `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
}

func (*PubSubMessage) Descriptor 

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

func (*PubSubMessage) GetData 

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

func (*PubSubMessage) GetFrom 

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

func (*PubSubMessage) GetKey 

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

func (*PubSubMessage) GetSeqno 

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

func (*PubSubMessage) GetSignature 

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

func (*PubSubMessage) GetTopicIDs 

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

func (*PubSubMessage) Marshal 

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

func (*PubSubMessage) MarshalTo 

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

func (*PubSubMessage) MarshalToSizedBuffer 

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

func (*PubSubMessage) ProtoMessage 

func (*PubSubMessage) ProtoMessage()

func (*PubSubMessage) Reset 

func (m *PubSubMessage) Reset()

func (*PubSubMessage) Size 

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

func (*PubSubMessage) String 

func (m *PubSubMessage) String() string

func (*PubSubMessage) Unmarshal 

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

func (*PubSubMessage) XXX_DiscardUnknown 

func (m *PubSubMessage) XXX_DiscardUnknown()

func (*PubSubMessage) XXX_Marshal 

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

func (*PubSubMessage) XXX_Merge 

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

func (*PubSubMessage) XXX_Size 

func (m *PubSubMessage) XXX_Size() int

func (*PubSubMessage) XXX_Unmarshal 

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

type PubSubPeer 

type PubSubPeer struct {
	// the topic this peer belongs to
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// the id of this peer
	PeerID string `protobuf:"bytes,2,opt,name=peerID,proto3" json:"peerID,omitempty"`
}

represents an individual pubsub peer

func (*PubSubPeer) Descriptor 

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

func (*PubSubPeer) GetPeerID 

func (m *PubSubPeer) GetPeerID() string

func (*PubSubPeer) GetTopic 

func (m *PubSubPeer) GetTopic() string

func (*PubSubPeer) Marshal 

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

func (*PubSubPeer) MarshalTo 

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

func (*PubSubPeer) MarshalToSizedBuffer 

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

func (*PubSubPeer) ProtoMessage 

func (*PubSubPeer) ProtoMessage()

func (*PubSubPeer) Reset 

func (m *PubSubPeer) Reset()

func (*PubSubPeer) Size 

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

func (*PubSubPeer) String 

func (m *PubSubPeer) String() string

func (*PubSubPeer) Unmarshal 

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

func (*PubSubPeer) XXX_DiscardUnknown 

func (m *PubSubPeer) XXX_DiscardUnknown()

func (*PubSubPeer) XXX_Marshal 

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

func (*PubSubPeer) XXX_Merge 

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

func (*PubSubPeer) XXX_Size 

func (m *PubSubPeer) XXX_Size() int

func (*PubSubPeer) XXX_Unmarshal 

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

type PubSubRequest 

type PubSubRequest struct {
	// indicates the particular PubSubAPI request being performed
	RequestType PSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.PSREQTYPE" json:"requestType,omitempty"`
	// topics to request peers from, or publish data to
	// sent by: PS_LIST_PEERS, PS_SUBSCRIBE, PS_PUBLISH
	Topics []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	// data to sent to topics
	// sent by: PS_PUBLISH
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*PubSubRequest) Descriptor 

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

func (*PubSubRequest) GetData 

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

func (*PubSubRequest) GetRequestType 

func (m *PubSubRequest) GetRequestType() PSREQTYPE

func (*PubSubRequest) GetTopics 

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

func (*PubSubRequest) Marshal 

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

func (*PubSubRequest) MarshalTo 

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

func (*PubSubRequest) MarshalToSizedBuffer 

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

func (*PubSubRequest) ProtoMessage 

func (*PubSubRequest) ProtoMessage()

func (*PubSubRequest) Reset 

func (m *PubSubRequest) Reset()

func (*PubSubRequest) Size 

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

func (*PubSubRequest) String 

func (m *PubSubRequest) String() string

func (*PubSubRequest) Unmarshal 

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

func (*PubSubRequest) XXX_DiscardUnknown 

func (m *PubSubRequest) XXX_DiscardUnknown()

func (*PubSubRequest) XXX_Marshal 

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

func (*PubSubRequest) XXX_Merge 

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

func (*PubSubRequest) XXX_Size 

func (m *PubSubRequest) XXX_Size() int

func (*PubSubRequest) XXX_Unmarshal 

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

type PubSubResponse 

type PubSubResponse struct {
	// indicates the particular PubSubAPI request being performed
	RequestType PSREQTYPE `protobuf:"varint,1,opt,name=requestType,proto3,enum=pb.PSREQTYPE" json:"requestType,omitempty"`
	// messages we have received from a topic
	// sent by: PS_SUBSCRIBE
	Message []*PubSubMessage `protobuf:"bytes,2,rep,name=message,proto3" json:"message,omitempty"`
	// topic names
	// sent by: PS_GET_TOPICS
	Topics []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"`
	// pubsub peers
	// sent by: PS_LIST_PEERS
	Peers []*PubSubPeer `protobuf:"bytes,4,rep,name=peers,proto3" json:"peers,omitempty"`
}

func (*PubSubResponse) Descriptor 

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

func (*PubSubResponse) GetMessage 

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

func (*PubSubResponse) GetPeers 

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

func (*PubSubResponse) GetRequestType 

func (m *PubSubResponse) GetRequestType() PSREQTYPE

func (*PubSubResponse) GetTopics 

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

func (*PubSubResponse) Marshal 

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

func (*PubSubResponse) MarshalTo 

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

func (*PubSubResponse) MarshalToSizedBuffer 

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

func (*PubSubResponse) ProtoMessage 

func (*PubSubResponse) ProtoMessage()

func (*PubSubResponse) Reset 

func (m *PubSubResponse) Reset()

func (*PubSubResponse) Size 

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

func (*PubSubResponse) String 

func (m *PubSubResponse) String() string

func (*PubSubResponse) Unmarshal 

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

func (*PubSubResponse) XXX_DiscardUnknown 

func (m *PubSubResponse) XXX_DiscardUnknown()

func (*PubSubResponse) XXX_Marshal 

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

func (*PubSubResponse) XXX_Merge 

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

func (*PubSubResponse) XXX_Size 

func (m *PubSubResponse) XXX_Size() int

func (*PubSubResponse) XXX_Unmarshal 

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

type PutResponse 

type PutResponse struct {
	// hash is hash/cid (content identifier) of the data that was stored
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

PutResponse is a response to any data storage (put) requests

func (*PutResponse) Descriptor 

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

func (*PutResponse) GetHash 

func (m *PutResponse) GetHash() string

func (*PutResponse) Marshal 

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

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

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

func (*UnimplementedAdminAPIServer) RefCount 

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

type UnimplementedFileAPIServer 

type UnimplementedFileAPIServer struct {
}

UnimplementedFileAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedFileAPIServer) DownloadFile 

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

func (*UnimplementedFileAPIServer) UploadFile 

func (*UnimplementedFileAPIServer) UploadFile(srv FileAPI_UploadFileServer) error

type UnimplementedNameSysAPIServer 

type UnimplementedNameSysAPIServer struct {
}

UnimplementedNameSysAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedNameSysAPIServer) NameSysPublish 

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

func (*UnimplementedNameSysAPIServer) NameSysResolve 

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

func (*UnimplementedNameSysAPIServer) NameSysResolveAsync 

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

type UnimplementedNodeAPIServer 

type UnimplementedNodeAPIServer struct {
}

UnimplementedNodeAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeAPIServer) Blockstore 

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

func (*UnimplementedNodeAPIServer) ConnMgmt 

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

func (*UnimplementedNodeAPIServer) Dag 

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

func (*UnimplementedNodeAPIServer) Extras 

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

func (*UnimplementedNodeAPIServer) Keystore 

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

func (*UnimplementedNodeAPIServer) P2P 

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

func (*UnimplementedNodeAPIServer) Persist 

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

type UnimplementedPubSubAPIServer 

type UnimplementedPubSubAPIServer struct {
}

UnimplementedPubSubAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedPubSubAPIServer) PubSub 

func (*UnimplementedPubSubAPIServer) PubSub(srv PubSubAPI_PubSubServer) error

type UnimplementedStatusAPIServer 

type UnimplementedStatusAPIServer struct {
}

UnimplementedStatusAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedStatusAPIServer) Status 

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

func (*UnimplementedStatusAPIServer) Version 

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

type UploadOptions 

type UploadOptions struct {
	// specifes the multihash function to use
	MultiHash string `protobuf:"bytes,1,opt,name=multiHash,proto3" json:"multiHash,omitempty"`
	// specifies the dag layout (balanced, tricklet)
	Layout string `protobuf:"bytes,2,opt,name=layout,proto3" json:"layout,omitempty"`
	// specifies the chunker type (rabin, default, etc...)
	Chunker string `protobuf:"bytes,3,opt,name=chunker,proto3" json:"chunker,omitempty"`
}

UploadOptions allows controlling the parameters of a file upload

func (*UploadOptions) Descriptor 

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

func (*UploadOptions) GetChunker 

func (m *UploadOptions) GetChunker() string

func (*UploadOptions) GetLayout 

func (m *UploadOptions) GetLayout() string

func (*UploadOptions) GetMultiHash 

func (m *UploadOptions) GetMultiHash() string

func (*UploadOptions) Marshal 

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

func (*UploadOptions) MarshalTo 

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

func (*UploadOptions) MarshalToSizedBuffer 

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

func (*UploadOptions) ProtoMessage 

func (*UploadOptions) ProtoMessage()

func (*UploadOptions) Reset 

func (m *UploadOptions) Reset()

func (*UploadOptions) Size 

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

func (*UploadOptions) String 

func (m *UploadOptions) String() string

func (*UploadOptions) Unmarshal 

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

func (*UploadOptions) XXX_DiscardUnknown 

func (m *UploadOptions) XXX_DiscardUnknown()

func (*UploadOptions) XXX_Marshal 

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

func (*UploadOptions) XXX_Merge 

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

func (*UploadOptions) XXX_Size 

func (m *UploadOptions) XXX_Size() int

func (*UploadOptions) XXX_Unmarshal 

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

type UploadRequest 

type UploadRequest struct {
	// blob is a single chunk of data
	Blob *Blob `protobuf:"bytes,1,opt,name=blob,proto3" json:"blob,omitempty"`
	// options allows setting the optoins for this upload
	Options *UploadOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
}

UploadRequest is used to upload data as a UnixFS object

func (*UploadRequest) Descriptor 

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

func (*UploadRequest) GetBlob 

func (m *UploadRequest) GetBlob() *Blob

func (*UploadRequest) GetOptions 

func (m *UploadRequest) GetOptions() *UploadOptions

func (*UploadRequest) Marshal 

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

func (*UploadRequest) MarshalTo 

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

func (*UploadRequest) MarshalToSizedBuffer 

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

func (*UploadRequest) ProtoMessage 

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) Reset 

func (m *UploadRequest) Reset()

func (*UploadRequest) Size 

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

func (*UploadRequest) String 

func (m *UploadRequest) String() string

func (*UploadRequest) Unmarshal 

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

func (*UploadRequest) XXX_DiscardUnknown 

func (m *UploadRequest) XXX_DiscardUnknown()

func (*UploadRequest) XXX_Marshal 

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

func (*UploadRequest) XXX_Merge 

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

func (*UploadRequest) XXX_Size 

func (m *UploadRequest) XXX_Size() int

func (*UploadRequest) XXX_Unmarshal 

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

type VersionResponse 

type VersionResponse struct {
	// version denotes the github version that was present when the api was built
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
}

VersionResponse is used to return API version information

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) Marshal 

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

func (*VersionResponse) MarshalTo 

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

func (*VersionResponse) MarshalToSizedBuffer 

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

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) Size 

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

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) Unmarshal 

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

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

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

func (*VersionResponse) XXX_Merge 

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

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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