pb

package
v0.0.9 Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2023 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

Functions

This section is empty.

Types

type FileRequest added in v0.0.9

type FileRequest struct {
	MessageData *Messagedata `protobuf:"bytes,1,opt,name=MessageData,json=messageData,proto3" json:"MessageData,omitempty"`
	FileName    string       `protobuf:"bytes,2,opt,name=FileName,json=fileName,proto3" json:"FileName,omitempty"`
	FileSize    uint64       `protobuf:"varint,3,opt,name=FileSize,json=fileSize,proto3" json:"FileSize,omitempty"`
	FileType    uint32       `protobuf:"varint,4,opt,name=FileType,json=fileType,proto3" json:"FileType,omitempty"`
	DataLength  uint32       `protobuf:"varint,5,opt,name=DataLength,json=dataLength,proto3" json:"DataLength,omitempty"`
	Data        []byte       `protobuf:"bytes,6,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

a protocol define a set of reuqest and responses

func (*FileRequest) Descriptor deprecated added in v0.0.9

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

Deprecated: Use FileRequest.ProtoReflect.Descriptor instead.

func (*FileRequest) GetData added in v0.0.9

func (x *FileRequest) GetData() []byte

func (*FileRequest) GetDataLength added in v0.0.9

func (x *FileRequest) GetDataLength() uint32

func (*FileRequest) GetFileName added in v0.0.9

func (x *FileRequest) GetFileName() string

func (*FileRequest) GetFileSize added in v0.0.9

func (x *FileRequest) GetFileSize() uint64

func (*FileRequest) GetFileType added in v0.0.9

func (x *FileRequest) GetFileType() uint32

func (*FileRequest) GetMessageData added in v0.0.9

func (x *FileRequest) GetMessageData() *Messagedata

func (*FileRequest) ProtoMessage added in v0.0.9

func (*FileRequest) ProtoMessage()

func (*FileRequest) ProtoReflect added in v0.0.9

func (x *FileRequest) ProtoReflect() protoreflect.Message

func (*FileRequest) Reset added in v0.0.9

func (x *FileRequest) Reset()

func (*FileRequest) String added in v0.0.9

func (x *FileRequest) String() string

type FileResponse added in v0.0.9

type FileResponse struct {
	MessageData *Messagedata `protobuf:"bytes,1,opt,name=MessageData,json=messageData,proto3" json:"MessageData,omitempty"`
	// Code indicates the result of this transfer
	Code uint32 `protobuf:"varint,2,opt,name=Code,json=code,proto3" json:"Code,omitempty"`
	// contains filtered or unexported fields
}

func (*FileResponse) Descriptor deprecated added in v0.0.9

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

Deprecated: Use FileResponse.ProtoReflect.Descriptor instead.

func (*FileResponse) GetCode added in v0.0.9

func (x *FileResponse) GetCode() uint32

func (*FileResponse) GetMessageData added in v0.0.9

func (x *FileResponse) GetMessageData() *Messagedata

func (*FileResponse) ProtoMessage added in v0.0.9

func (*FileResponse) ProtoMessage()

func (*FileResponse) ProtoReflect added in v0.0.9

func (x *FileResponse) ProtoReflect() protoreflect.Message

func (*FileResponse) Reset added in v0.0.9

func (x *FileResponse) Reset()

func (*FileResponse) String added in v0.0.9

func (x *FileResponse) String() string

type IdleRequest added in v0.0.9

type IdleRequest struct {
	PeerIndex uint64 `protobuf:"varint,1,opt,name=PeerIndex,json=peerIndex,proto3" json:"PeerIndex,omitempty"`
	Sign      []byte `protobuf:"bytes,2,opt,name=Sign,json=sign,proto3" json:"Sign,omitempty"`
	// contains filtered or unexported fields
}

a protocol define a set of reuqest and responses

func (*IdleRequest) Descriptor deprecated added in v0.0.9

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

Deprecated: Use IdleRequest.ProtoReflect.Descriptor instead.

func (*IdleRequest) GetPeerIndex added in v0.0.9

func (x *IdleRequest) GetPeerIndex() uint64

func (*IdleRequest) GetSign added in v0.0.9

func (x *IdleRequest) GetSign() []byte

func (*IdleRequest) ProtoMessage added in v0.0.9

func (*IdleRequest) ProtoMessage()

func (*IdleRequest) ProtoReflect added in v0.0.9

func (x *IdleRequest) ProtoReflect() protoreflect.Message

func (*IdleRequest) Reset added in v0.0.9

func (x *IdleRequest) Reset()

func (*IdleRequest) String added in v0.0.9

func (x *IdleRequest) String() string

type IdleResponse added in v0.0.9

type IdleResponse struct {
	Code uint32 `protobuf:"varint,2,opt,name=Code,json=code,proto3" json:"Code,omitempty"`
	// contains filtered or unexported fields
}

func (*IdleResponse) Descriptor deprecated added in v0.0.9

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

Deprecated: Use IdleResponse.ProtoReflect.Descriptor instead.

func (*IdleResponse) GetCode added in v0.0.9

func (x *IdleResponse) GetCode() uint32

func (*IdleResponse) ProtoMessage added in v0.0.9

func (*IdleResponse) ProtoMessage()

func (*IdleResponse) ProtoReflect added in v0.0.9

func (x *IdleResponse) ProtoReflect() protoreflect.Message

func (*IdleResponse) Reset added in v0.0.9

func (x *IdleResponse) Reset()

func (*IdleResponse) String added in v0.0.9

func (x *IdleResponse) String() string

type MessageData

type MessageData struct {
	// shared between all requests
	ClientVersion        string   `protobuf:"bytes,1,opt,name=clientVersion,proto3" json:"clientVersion,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	NodeId               string   `protobuf:"bytes,3,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	NodePubKey           []byte   `protobuf:"bytes,4,opt,name=nodePubKey,proto3" json:"nodePubKey,omitempty"`
	Sign                 []byte   `protobuf:"bytes,5,opt,name=sign,proto3" json:"sign,omitempty"`
	Timestamp            int64    `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Gossip               bool     `protobuf:"varint,7,opt,name=gossip,proto3" json:"gossip,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

designed to be shared between all app protocols

func (*MessageData) Descriptor

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

func (*MessageData) GetClientVersion

func (m *MessageData) GetClientVersion() string

func (*MessageData) GetGossip

func (m *MessageData) GetGossip() bool

func (*MessageData) GetId

func (m *MessageData) GetId() string

func (*MessageData) GetNodeId

func (m *MessageData) GetNodeId() string

func (*MessageData) GetNodePubKey

func (m *MessageData) GetNodePubKey() []byte

func (*MessageData) GetSign

func (m *MessageData) GetSign() []byte

func (*MessageData) GetTimestamp

func (m *MessageData) GetTimestamp() int64

func (*MessageData) ProtoMessage

func (*MessageData) ProtoMessage()

func (*MessageData) Reset

func (m *MessageData) Reset()

func (*MessageData) String

func (m *MessageData) String() string

func (*MessageData) XXX_DiscardUnknown

func (m *MessageData) XXX_DiscardUnknown()

func (*MessageData) XXX_Marshal

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

func (*MessageData) XXX_Merge

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

func (*MessageData) XXX_Size

func (m *MessageData) XXX_Size() int

func (*MessageData) XXX_Unmarshal

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

type Messagedata added in v0.0.9

type Messagedata struct {

	// shared between all requests
	Timestamp int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix time
	Id        string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                // allows requesters to use request data when processing a response
	// contains filtered or unexported fields
}

designed to be shared between all app protocols

func (*Messagedata) Descriptor deprecated added in v0.0.9

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

Deprecated: Use Messagedata.ProtoReflect.Descriptor instead.

func (*Messagedata) GetId added in v0.0.9

func (x *Messagedata) GetId() string

func (*Messagedata) GetTimestamp added in v0.0.9

func (x *Messagedata) GetTimestamp() int64

func (*Messagedata) ProtoMessage added in v0.0.9

func (*Messagedata) ProtoMessage()

func (*Messagedata) ProtoReflect added in v0.0.9

func (x *Messagedata) ProtoReflect() protoreflect.Message

func (*Messagedata) Reset added in v0.0.9

func (x *Messagedata) Reset()

func (*Messagedata) String added in v0.0.9

func (x *Messagedata) String() string

type MusRequest added in v0.0.9

type MusRequest struct {
	MessageData *Messagedata `protobuf:"bytes,1,opt,name=MessageData,json=messageData,proto3" json:"MessageData,omitempty"`
	// contains filtered or unexported fields
}

a protocol define a set of reuqest and responses

func (*MusRequest) Descriptor deprecated added in v0.0.9

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

Deprecated: Use MusRequest.ProtoReflect.Descriptor instead.

func (*MusRequest) GetMessageData added in v0.0.9

func (x *MusRequest) GetMessageData() *Messagedata

func (*MusRequest) ProtoMessage added in v0.0.9

func (*MusRequest) ProtoMessage()

func (*MusRequest) ProtoReflect added in v0.0.9

func (x *MusRequest) ProtoReflect() protoreflect.Message

func (*MusRequest) Reset added in v0.0.9

func (x *MusRequest) Reset()

func (*MusRequest) String added in v0.0.9

func (x *MusRequest) String() string

type MusResponse added in v0.0.9

type MusResponse struct {
	MessageData *Messagedata `protobuf:"bytes,1,opt,name=MessageData,json=messageData,proto3" json:"MessageData,omitempty"`
	// Code indicates the result of this transfer
	Code uint32 `protobuf:"varint,2,opt,name=Code,json=code,proto3" json:"Code,omitempty"`
	// contains filtered or unexported fields
}

func (*MusResponse) Descriptor deprecated added in v0.0.9

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

Deprecated: Use MusResponse.ProtoReflect.Descriptor instead.

func (*MusResponse) GetCode added in v0.0.9

func (x *MusResponse) GetCode() uint32

func (*MusResponse) GetMessageData added in v0.0.9

func (x *MusResponse) GetMessageData() *Messagedata

func (*MusResponse) ProtoMessage added in v0.0.9

func (*MusResponse) ProtoMessage()

func (*MusResponse) ProtoReflect added in v0.0.9

func (x *MusResponse) ProtoReflect() protoreflect.Message

func (*MusResponse) Reset added in v0.0.9

func (x *MusResponse) Reset()

func (*MusResponse) String added in v0.0.9

func (x *MusResponse) String() string

type ReadfileRequest

type ReadfileRequest struct {
	// Roothash uniquely identifies a user data
	Roothash string `protobuf:"bytes,1,opt,name=Roothash,json=roothash,proto3" json:"Roothash,omitempty"`
	// Datahash is the currently written data hash value
	Datahash string `protobuf:"bytes,2,opt,name=Datahash,json=datahash,proto3" json:"Datahash,omitempty"`
	// MessageData is a generic message
	MessageData *MessageData `protobuf:"bytes,3,opt,name=messageData,proto3" json:"messageData,omitempty"`
	// Offset is the offset that the reader wants to read
	Offset               int64    `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

a protocol define a set of reuqest and responses

func (*ReadfileRequest) Descriptor

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

func (*ReadfileRequest) GetDatahash

func (m *ReadfileRequest) GetDatahash() string

func (*ReadfileRequest) GetMessageData

func (m *ReadfileRequest) GetMessageData() *MessageData

func (*ReadfileRequest) GetOffset

func (m *ReadfileRequest) GetOffset() int64

func (*ReadfileRequest) GetRoothash

func (m *ReadfileRequest) GetRoothash() string

func (*ReadfileRequest) ProtoMessage

func (*ReadfileRequest) ProtoMessage()

func (*ReadfileRequest) Reset

func (m *ReadfileRequest) Reset()

func (*ReadfileRequest) String

func (m *ReadfileRequest) String() string

func (*ReadfileRequest) XXX_DiscardUnknown

func (m *ReadfileRequest) XXX_DiscardUnknown()

func (*ReadfileRequest) XXX_Marshal

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

func (*ReadfileRequest) XXX_Merge

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

func (*ReadfileRequest) XXX_Size

func (m *ReadfileRequest) XXX_Size() int

func (*ReadfileRequest) XXX_Unmarshal

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

type ReadfileResponse

type ReadfileResponse struct {
	// Data is the returned data
	Data []byte `protobuf:"bytes,1,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
	// MessageData is a generic message
	MessageData *MessageData `protobuf:"bytes,2,opt,name=messageData,proto3" json:"messageData,omitempty"`
	// Offset is the data offset returned by the peer
	Offset int64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// Code indicates the result of this transfer
	Code uint32 `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	// Length is the returned data length
	Length               uint32   `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadfileResponse) Descriptor

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

func (*ReadfileResponse) GetCode

func (m *ReadfileResponse) GetCode() uint32

func (*ReadfileResponse) GetData

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

func (*ReadfileResponse) GetLength

func (m *ReadfileResponse) GetLength() uint32

func (*ReadfileResponse) GetMessageData

func (m *ReadfileResponse) GetMessageData() *MessageData

func (*ReadfileResponse) GetOffset

func (m *ReadfileResponse) GetOffset() int64

func (*ReadfileResponse) ProtoMessage

func (*ReadfileResponse) ProtoMessage()

func (*ReadfileResponse) Reset

func (m *ReadfileResponse) Reset()

func (*ReadfileResponse) String

func (m *ReadfileResponse) String() string

func (*ReadfileResponse) XXX_DiscardUnknown

func (m *ReadfileResponse) XXX_DiscardUnknown()

func (*ReadfileResponse) XXX_Marshal

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

func (*ReadfileResponse) XXX_Merge

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

func (*ReadfileResponse) XXX_Size

func (m *ReadfileResponse) XXX_Size() int

func (*ReadfileResponse) XXX_Unmarshal

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

type TagRequest added in v0.0.9

type TagRequest struct {
	MessageData *Messagedata `protobuf:"bytes,1,opt,name=MessageData,json=messageData,proto3" json:"MessageData,omitempty"`
	FileName    string       `protobuf:"bytes,2,opt,name=FileName,json=fileName,proto3" json:"FileName,omitempty"`
	CustomData  string       `protobuf:"bytes,3,opt,name=CustomData,json=customData,proto3" json:"CustomData,omitempty"`
	BlockNum    int64        `protobuf:"varint,4,opt,name=BlockNum,json=blockNum,proto3" json:"BlockNum,omitempty"`
	// contains filtered or unexported fields
}

a protocol define a set of reuqest and responses

func (*TagRequest) Descriptor deprecated added in v0.0.9

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

Deprecated: Use TagRequest.ProtoReflect.Descriptor instead.

func (*TagRequest) GetBlockNum added in v0.0.9

func (x *TagRequest) GetBlockNum() int64

func (*TagRequest) GetCustomData added in v0.0.9

func (x *TagRequest) GetCustomData() string

func (*TagRequest) GetFileName added in v0.0.9

func (x *TagRequest) GetFileName() string

func (*TagRequest) GetMessageData added in v0.0.9

func (x *TagRequest) GetMessageData() *Messagedata

func (*TagRequest) ProtoMessage added in v0.0.9

func (*TagRequest) ProtoMessage()

func (*TagRequest) ProtoReflect added in v0.0.9

func (x *TagRequest) ProtoReflect() protoreflect.Message

func (*TagRequest) Reset added in v0.0.9

func (x *TagRequest) Reset()

func (*TagRequest) String added in v0.0.9

func (x *TagRequest) String() string

type TagResponse added in v0.0.9

type TagResponse struct {
	MessageData *Messagedata `protobuf:"bytes,1,opt,name=MessageData,json=messageData,proto3" json:"MessageData,omitempty"`
	// Code indicates the result of this transfer
	Code uint32 `protobuf:"varint,2,opt,name=Code,json=code,proto3" json:"Code,omitempty"`
	// contains filtered or unexported fields
}

func (*TagResponse) Descriptor deprecated added in v0.0.9

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

Deprecated: Use TagResponse.ProtoReflect.Descriptor instead.

func (*TagResponse) GetCode added in v0.0.9

func (x *TagResponse) GetCode() uint32

func (*TagResponse) GetMessageData added in v0.0.9

func (x *TagResponse) GetMessageData() *Messagedata

func (*TagResponse) ProtoMessage added in v0.0.9

func (*TagResponse) ProtoMessage()

func (*TagResponse) ProtoReflect added in v0.0.9

func (x *TagResponse) ProtoReflect() protoreflect.Message

func (*TagResponse) Reset added in v0.0.9

func (x *TagResponse) Reset()

func (*TagResponse) String added in v0.0.9

func (x *TagResponse) String() string

type WritefileRequest

type WritefileRequest struct {
	// Roothash uniquely identifies a user data
	Roothash string `protobuf:"bytes,1,opt,name=Roothash,json=roothash,proto3" json:"Roothash,omitempty"`
	// Datahash is the currently written data hash value
	Datahash string `protobuf:"bytes,2,opt,name=Datahash,json=datahash,proto3" json:"Datahash,omitempty"`
	// Data is the data written this time
	Data []byte `protobuf:"bytes,3,opt,name=Data,json=data,proto3" json:"Data,omitempty"`
	// MessageData is a generic message
	MessageData *MessageData `protobuf:"bytes,4,opt,name=messageData,proto3" json:"messageData,omitempty"`
	// Offset is the offset of this write
	Offset int64 `protobuf:"varint,5,opt,name=Offset,json=offset,proto3" json:"Offset,omitempty"`
	// Length is the length of the data written this time
	Length               uint32   `protobuf:"varint,6,opt,name=Length,json=length,proto3" json:"Length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

a protocol define a set of reuqest and responses

func (*WritefileRequest) Descriptor

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

func (*WritefileRequest) GetData

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

func (*WritefileRequest) GetDatahash

func (m *WritefileRequest) GetDatahash() string

func (*WritefileRequest) GetLength

func (m *WritefileRequest) GetLength() uint32

func (*WritefileRequest) GetMessageData

func (m *WritefileRequest) GetMessageData() *MessageData

func (*WritefileRequest) GetOffset

func (m *WritefileRequest) GetOffset() int64

func (*WritefileRequest) GetRoothash

func (m *WritefileRequest) GetRoothash() string

func (*WritefileRequest) ProtoMessage

func (*WritefileRequest) ProtoMessage()

func (*WritefileRequest) Reset

func (m *WritefileRequest) Reset()

func (*WritefileRequest) String

func (m *WritefileRequest) String() string

func (*WritefileRequest) XXX_DiscardUnknown

func (m *WritefileRequest) XXX_DiscardUnknown()

func (*WritefileRequest) XXX_Marshal

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

func (*WritefileRequest) XXX_Merge

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

func (*WritefileRequest) XXX_Size

func (m *WritefileRequest) XXX_Size() int

func (*WritefileRequest) XXX_Unmarshal

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

type WritefileResponse

type WritefileResponse struct {
	// MessageData is a generic message
	MessageData *MessageData `protobuf:"bytes,1,opt,name=messageData,proto3" json:"messageData,omitempty"`
	// Offset is the write offset the receiver wants
	Offset int64 `protobuf:"varint,2,opt,name=Offset,json=offset,proto3" json:"Offset,omitempty"`
	// Code indicates the result of this transfer
	Code                 uint32   `protobuf:"varint,3,opt,name=Code,json=code,proto3" json:"Code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WritefileResponse) Descriptor

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

func (*WritefileResponse) GetCode

func (m *WritefileResponse) GetCode() uint32

func (*WritefileResponse) GetMessageData

func (m *WritefileResponse) GetMessageData() *MessageData

func (*WritefileResponse) GetOffset

func (m *WritefileResponse) GetOffset() int64

func (*WritefileResponse) ProtoMessage

func (*WritefileResponse) ProtoMessage()

func (*WritefileResponse) Reset

func (m *WritefileResponse) Reset()

func (*WritefileResponse) String

func (m *WritefileResponse) String() string

func (*WritefileResponse) XXX_DiscardUnknown

func (m *WritefileResponse) XXX_DiscardUnknown()

func (*WritefileResponse) XXX_Marshal

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

func (*WritefileResponse) XXX_Merge

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

func (*WritefileResponse) XXX_Size

func (m *WritefileResponse) XXX_Size() int

func (*WritefileResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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