graphsync_message_pb

package
v0.0.9 Latest Latest
Warning

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

Go to latest
Published: Aug 12, 2020 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"`
	Extensions map[string][]byte `` /* 154-byte string literal not displayed */
	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) GetExtensions

func (m *Message_Request) GetExtensions() map[string][]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"`
	Extensions map[string][]byte `` /* 154-byte string literal not displayed */
}

func (*Message_Response) Descriptor

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

func (*Message_Response) GetExtensions

func (m *Message_Response) GetExtensions() map[string][]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

Jump to

Keyboard shortcuts

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