graphsync_message_pb

package
v0.0.1-filecoin Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2019 License: Apache-2.0, MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type Message 

type Message struct {
	// the actual data included in this message
	CompleteRequestList bool               `protobuf:"varint,1,opt,name=completeRequestList,proto3" json:"completeRequestList,omitempty"`
	Requests            []Message_Request  `protobuf:"bytes,2,rep,name=requests" json:"requests"`
	Responses           []Message_Response `protobuf:"bytes,3,rep,name=responses" json:"responses"`
	Data                []Message_Block    `protobuf:"bytes,4,rep,name=data" json:"data"`
}

func (*Message) Descriptor 

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

func (*Message) GetCompleteRequestList 

func (m *Message) GetCompleteRequestList() bool

func (*Message) GetData 

func (m *Message) GetData() []Message_Block

func (*Message) GetRequests 

func (m *Message) GetRequests() []Message_Request

func (*Message) GetResponses 

func (m *Message) GetResponses() []Message_Response

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

func (dst *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Message_Block 

type Message_Block struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Message_Block) Descriptor 

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

func (*Message_Block) GetData 

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

func (*Message_Block) GetPrefix 

func (m *Message_Block) GetPrefix() []byte

func (*Message_Block) Marshal 

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

func (*Message_Block) MarshalTo 

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

func (*Message_Block) ProtoMessage 

func (*Message_Block) ProtoMessage()

func (*Message_Block) Reset 

func (m *Message_Block) Reset()

func (*Message_Block) Size 

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

func (*Message_Block) String 

func (m *Message_Block) String() string

func (*Message_Block) Unmarshal 

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

func (*Message_Block) XXX_DiscardUnknown 

func (m *Message_Block) XXX_DiscardUnknown()

func (*Message_Block) XXX_Marshal 

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

func (*Message_Block) XXX_Merge 

func (dst *Message_Block) XXX_Merge(src proto.Message)

func (*Message_Block) XXX_Size 

func (m *Message_Block) XXX_Size() int

func (*Message_Block) XXX_Unmarshal 

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

type Message_Request 

type Message_Request struct {
	Id       int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Root     []byte `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	Selector []byte `protobuf:"bytes,3,opt,name=selector,proto3" json:"selector,omitempty"`
	Extra    []byte `protobuf:"bytes,4,opt,name=extra,proto3" json:"extra,omitempty"`
	Priority int32  `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Cancel   bool   `protobuf:"varint,6,opt,name=cancel,proto3" json:"cancel,omitempty"`
}

func (*Message_Request) Descriptor 

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

func (*Message_Request) GetCancel 

func (m *Message_Request) GetCancel() bool

func (*Message_Request) GetExtra 

func (m *Message_Request) GetExtra() []byte

func (*Message_Request) GetId 

func (m *Message_Request) GetId() int32

func (*Message_Request) GetPriority 

func (m *Message_Request) GetPriority() int32

func (*Message_Request) GetRoot 

func (m *Message_Request) GetRoot() []byte

func (*Message_Request) GetSelector 

func (m *Message_Request) GetSelector() []byte

func (*Message_Request) Marshal 

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

func (*Message_Request) MarshalTo 

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

func (*Message_Request) ProtoMessage 

func (*Message_Request) ProtoMessage()

func (*Message_Request) Reset 

func (m *Message_Request) Reset()

func (*Message_Request) Size 

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

func (*Message_Request) String 

func (m *Message_Request) String() string

func (*Message_Request) Unmarshal 

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

func (*Message_Request) XXX_DiscardUnknown 

func (m *Message_Request) XXX_DiscardUnknown()

func (*Message_Request) XXX_Marshal 

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

func (*Message_Request) XXX_Merge 

func (dst *Message_Request) XXX_Merge(src proto.Message)

func (*Message_Request) XXX_Size 

func (m *Message_Request) XXX_Size() int

func (*Message_Request) XXX_Unmarshal 

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

type Message_Response 

type Message_Response struct {
	Id     int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Status int32  `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Extra  []byte `protobuf:"bytes,3,opt,name=extra,proto3" json:"extra,omitempty"`
}

func (*Message_Response) Descriptor 

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

func (*Message_Response) GetExtra 

func (m *Message_Response) GetExtra() []byte

func (*Message_Response) GetId 

func (m *Message_Response) GetId() int32

func (*Message_Response) GetStatus 

func (m *Message_Response) GetStatus() int32

func (*Message_Response) Marshal 

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

func (*Message_Response) MarshalTo 

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

func (*Message_Response) ProtoMessage 

func (*Message_Response) ProtoMessage()

func (*Message_Response) Reset 

func (m *Message_Response) Reset()

func (*Message_Response) Size 

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

func (*Message_Response) String 

func (m *Message_Response) String() string

func (*Message_Response) Unmarshal 

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

func (*Message_Response) XXX_DiscardUnknown 

func (m *Message_Response) XXX_DiscardUnknown()

func (*Message_Response) XXX_Marshal 

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

func (*Message_Response) XXX_Merge 

func (dst *Message_Response) XXX_Merge(src proto.Message)

func (*Message_Response) XXX_Size 

func (m *Message_Response) XXX_Size() int

func (*Message_Response) XXX_Unmarshal 

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