pb

package
v0.0.10 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FileType_name = map[int32]string{
		0: "CustomData",
		1: "IdleData",
		2: "Mu",
		3: "Tag",
	}
	FileType_value = map[string]int32{
		"CustomData": 0,
		"IdleData":   1,
		"Mu":         2,
		"Tag":        3,
	}
)

Enum value maps for FileType.

View Source 
var File_file_proto protoreflect.FileDescriptor
View Source 
var File_mus_proto protoreflect.FileDescriptor
View Source 
var File_tag_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CustomDataTagRequest added in v0.0.10 

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

a protocol define a set of reuqest and responses

func (*CustomDataTagRequest) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use CustomDataTagRequest.ProtoReflect.Descriptor instead.

func (*CustomDataTagRequest) GetBlockNum added in v0.0.10 

func (x *CustomDataTagRequest) GetBlockNum() int64

func (*CustomDataTagRequest) GetCustomData added in v0.0.10 

func (x *CustomDataTagRequest) GetCustomData() string

func (*CustomDataTagRequest) GetFileName added in v0.0.10 

func (x *CustomDataTagRequest) GetFileName() string

func (*CustomDataTagRequest) ProtoMessage added in v0.0.10 

func (*CustomDataTagRequest) ProtoMessage()

func (*CustomDataTagRequest) ProtoReflect added in v0.0.10 

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

func (*CustomDataTagRequest) Reset added in v0.0.10 

func (x *CustomDataTagRequest) Reset()

func (*CustomDataTagRequest) String added in v0.0.10 

func (x *CustomDataTagRequest) String() string

type CustomDataTagResponse added in v0.0.10 

type CustomDataTagResponse struct {

	// Code indicates the result of this transfer
	Code uint32 `protobuf:"varint,1,opt,name=Code,json=code,proto3" json:"Code,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomDataTagResponse) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use CustomDataTagResponse.ProtoReflect.Descriptor instead.

func (*CustomDataTagResponse) GetCode added in v0.0.10 

func (x *CustomDataTagResponse) GetCode() uint32

func (*CustomDataTagResponse) ProtoMessage added in v0.0.10 

func (*CustomDataTagResponse) ProtoMessage()

func (*CustomDataTagResponse) ProtoReflect added in v0.0.10 

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

func (*CustomDataTagResponse) Reset added in v0.0.10 

func (x *CustomDataTagResponse) Reset()

func (*CustomDataTagResponse) String added in v0.0.10 

func (x *CustomDataTagResponse) String() string

type FileType added in v0.0.10 

type FileType int32
const (
	FileType_CustomData FileType = 0
	FileType_IdleData   FileType = 1
	FileType_Mu         FileType = 2
	FileType_Tag        FileType = 3
)

func (FileType) Descriptor added in v0.0.10 

func (FileType) Descriptor() protoreflect.EnumDescriptor

func (FileType) Enum added in v0.0.10 

func (x FileType) Enum() *FileType

func (FileType) EnumDescriptor deprecated added in v0.0.10 

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

Deprecated: Use FileType.Descriptor instead.

func (FileType) Number added in v0.0.10 

func (x FileType) Number() protoreflect.EnumNumber

func (FileType) String added in v0.0.10 

func (x FileType) String() string

func (FileType) Type added in v0.0.10 

func (FileType) Type() protoreflect.EnumType

type GetRequest added in v0.0.10 

type GetRequest struct {
	Type FileType `protobuf:"varint,1,opt,name=type,proto3,enum=FileType" json:"type,omitempty"`
	Hash string   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetHash added in v0.0.10 

func (x *GetRequest) GetHash() string

func (*GetRequest) GetType added in v0.0.10 

func (x *GetRequest) GetType() FileType

func (*GetRequest) ProtoMessage added in v0.0.10 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect added in v0.0.10 

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

func (*GetRequest) Reset added in v0.0.10 

func (x *GetRequest) Reset()

func (*GetRequest) String added in v0.0.10 

func (x *GetRequest) String() string

type GetResponse added in v0.0.10 

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

func (*GetResponse) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetCode added in v0.0.10 

func (x *GetResponse) GetCode() uint32

func (*GetResponse) GetSize added in v0.0.10 

func (x *GetResponse) GetSize() uint64

func (*GetResponse) ProtoMessage added in v0.0.10 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect added in v0.0.10 

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

func (*GetResponse) Reset added in v0.0.10 

func (x *GetResponse) Reset()

func (*GetResponse) String added in v0.0.10 

func (x *GetResponse) String() string

type IdleDataTagRequest added in v0.0.10 

type IdleDataTagRequest struct {
	FileSize  uint64 `protobuf:"varint,1,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	BlockNum  uint64 `protobuf:"varint,2,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	PeerIndex uint64 `protobuf:"varint,3,opt,name=peer_index,json=peerIndex,proto3" json:"peer_index,omitempty"`
	Sign      []byte `protobuf:"bytes,4,opt,name=sign,proto3" json:"sign,omitempty"`
	// contains filtered or unexported fields
}

a protocol define a set of reuqest and responses

func (*IdleDataTagRequest) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use IdleDataTagRequest.ProtoReflect.Descriptor instead.

func (*IdleDataTagRequest) GetBlockNum added in v0.0.10 

func (x *IdleDataTagRequest) GetBlockNum() uint64

func (*IdleDataTagRequest) GetFileSize added in v0.0.10 

func (x *IdleDataTagRequest) GetFileSize() uint64

func (*IdleDataTagRequest) GetPeerIndex added in v0.0.10 

func (x *IdleDataTagRequest) GetPeerIndex() uint64

func (*IdleDataTagRequest) GetSign added in v0.0.10 

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

func (*IdleDataTagRequest) ProtoMessage added in v0.0.10 

func (*IdleDataTagRequest) ProtoMessage()

func (*IdleDataTagRequest) ProtoReflect added in v0.0.10 

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

func (*IdleDataTagRequest) Reset added in v0.0.10 

func (x *IdleDataTagRequest) Reset()

func (*IdleDataTagRequest) String added in v0.0.10 

func (x *IdleDataTagRequest) String() string

type IdleDataTagResponse added in v0.0.10 

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

func (*IdleDataTagResponse) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use IdleDataTagResponse.ProtoReflect.Descriptor instead.

func (*IdleDataTagResponse) GetCode added in v0.0.10 

func (x *IdleDataTagResponse) GetCode() uint32

func (*IdleDataTagResponse) ProtoMessage added in v0.0.10 

func (*IdleDataTagResponse) ProtoMessage()

func (*IdleDataTagResponse) ProtoReflect added in v0.0.10 

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

func (*IdleDataTagResponse) Reset added in v0.0.10 

func (x *IdleDataTagResponse) Reset()

func (*IdleDataTagResponse) String added in v0.0.10 

func (x *IdleDataTagResponse) 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 MusRequest added in v0.0.9 

type MusRequest struct {
	// contains filtered or unexported fields
}

// Mus protocol 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) 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 {
	Code uint32 `protobuf:"varint,1,opt,name=Code,json=code,proto3" json:"Code,omitempty"`
	// Code indicates the result of this transfer
	MuHash string   `protobuf:"bytes,2,opt,name=mu_hash,json=muHash,proto3" json:"mu_hash,omitempty"`
	Name   []string `protobuf:"bytes,3,rep,name=name,proto3" json:"name,omitempty"`
	U      []string `protobuf:"bytes,4,rep,name=u,proto3" json:"u,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) GetMuHash added in v0.0.10 

func (x *MusResponse) GetMuHash() string

func (*MusResponse) GetName added in v0.0.10 

func (x *MusResponse) GetName() []string

func (*MusResponse) GetU added in v0.0.10 

func (x *MusResponse) GetU() []string

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 PutRequest added in v0.0.10 

type PutRequest struct {
	Type FileType `protobuf:"varint,1,opt,name=type,proto3,enum=FileType" json:"type,omitempty"`
	Hash string   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	Size uint64   `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetHash added in v0.0.10 

func (x *PutRequest) GetHash() string

func (*PutRequest) GetSize added in v0.0.10 

func (x *PutRequest) GetSize() uint64

func (*PutRequest) GetType added in v0.0.10 

func (x *PutRequest) GetType() FileType

func (*PutRequest) ProtoMessage added in v0.0.10 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect added in v0.0.10 

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

func (*PutRequest) Reset added in v0.0.10 

func (x *PutRequest) Reset()

func (*PutRequest) String added in v0.0.10 

func (x *PutRequest) String() string

type PutResponse added in v0.0.10 

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

func (*PutResponse) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetCode added in v0.0.10 

func (x *PutResponse) GetCode() uint32

func (*PutResponse) ProtoMessage added in v0.0.10 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect added in v0.0.10 

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

func (*PutResponse) Reset added in v0.0.10 

func (x *PutResponse) Reset()

func (*PutResponse) String added in v0.0.10 

func (x *PutResponse) 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 Request added in v0.0.10 

type Request struct {

	// Types that are assignable to Request:
	//	*Request_PutRequest
	//	*Request_GetRequest
	Request isRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetGetRequest added in v0.0.10 

func (x *Request) GetGetRequest() *GetRequest

func (*Request) GetPutRequest added in v0.0.10 

func (x *Request) GetPutRequest() *PutRequest

func (*Request) GetRequest added in v0.0.10 

func (m *Request) GetRequest() isRequest_Request

func (*Request) ProtoMessage added in v0.0.10 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect added in v0.0.10 

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

func (*Request) Reset added in v0.0.10 

func (x *Request) Reset()

func (*Request) String added in v0.0.10 

func (x *Request) String() string

type Request_GetRequest added in v0.0.10 

type Request_GetRequest struct {
	GetRequest *GetRequest `protobuf:"bytes,2,opt,name=getRequest,proto3,oneof"`
}

type Request_PutRequest added in v0.0.10 

type Request_PutRequest struct {
	PutRequest *PutRequest `protobuf:"bytes,1,opt,name=putRequest,proto3,oneof"`
}

type Response added in v0.0.10 

type Response struct {

	// Types that are assignable to Response:
	//	*Response_PutResponse
	//	*Response_GetResponse
	Response isResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetGetResponse added in v0.0.10 

func (x *Response) GetGetResponse() *GetResponse

func (*Response) GetPutResponse added in v0.0.10 

func (x *Response) GetPutResponse() *PutResponse

func (*Response) GetResponse added in v0.0.10 

func (m *Response) GetResponse() isResponse_Response

func (*Response) ProtoMessage added in v0.0.10 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect added in v0.0.10 

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

func (*Response) Reset added in v0.0.10 

func (x *Response) Reset()

func (*Response) String added in v0.0.10 

func (x *Response) String() string

type Response_GetResponse added in v0.0.10 

type Response_GetResponse struct {
	GetResponse *GetResponse `protobuf:"bytes,2,opt,name=getResponse,proto3,oneof"`
}

type Response_PutResponse added in v0.0.10 

type Response_PutResponse struct {
	PutResponse *PutResponse `protobuf:"bytes,1,opt,name=putResponse,proto3,oneof"`
}

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

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.