packet

type Acknowledgement struct {
	Latency int64 `protobuf:"varint,1,opt,name=latency,proto3" json:"latency,omitempty"`
	// contains filtered or unexported fields
}

type Configuration struct {
	StationId  uint32 `protobuf:"varint,1,opt,name=station_id,json=stationId,proto3" json:"station_id,omitempty"`
	ConfigData []byte `protobuf:"bytes,2,opt,name=config_data,json=configData,proto3" json:"config_data,omitempty"`
	// contains filtered or unexported fields
}

type DataContent struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ChunkIndex uint32 `protobuf:"varint,2,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`
	Checksum   uint32 `protobuf:"varint,3,opt,name=checksum,proto3" json:"checksum,omitempty"` // CRC32
	Data       []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type DataInterest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DataInterestResponse struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Checksum  uint32 `protobuf:"varint,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	NumChunks uint32 `protobuf:"varint,3,opt,name=num_chunks,json=numChunks,proto3" json:"num_chunks,omitempty"`
	// contains filtered or unexported fields
}

type DataRegister struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Freshness uint64 `protobuf:"varint,2,opt,name=freshness,proto3" json:"freshness,omitempty"` // in seconds
	Size      uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Checksum  uint32 `protobuf:"varint,4,opt,name=checksum,proto3" json:"checksum,omitempty"` // merkle tree, checksum of each chunk's checksum
	NumChunks uint32 `protobuf:"varint,5,opt,name=num_chunks,json=numChunks,proto3" json:"num_chunks,omitempty"`
	// contains filtered or unexported fields
}

type ErrorCode int32

type ErrorMessage struct {
	ErrorCode ErrorCode `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=rtdex.ErrorCode" json:"error_code,omitempty"`
	// contains filtered or unexported fields
}

type Heartbeat struct {
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type JoinRequest struct {
	Id                  uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace           string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AuthenticationToken uint32 `protobuf:"varint,3,opt,name=authentication_token,json=authenticationToken,proto3" json:"authentication_token,omitempty"`
	// contains filtered or unexported fields
}

type JoinResponse struct {
	SessionToken uint32 `protobuf:"varint,2,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`
	// contains filtered or unexported fields
}

type PacketHeader struct {
	ProtocolVersion uint32     `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	PacketUid       uint32     `protobuf:"varint,2,opt,name=packet_uid,json=packetUid,proto3" json:"packet_uid,omitempty"`
	PacketType      PacketType `protobuf:"varint,3,opt,name=packet_type,json=packetType,proto3,enum=rtdex.PacketType" json:"packet_type,omitempty"`
	SequenceNumber  uint32     `protobuf:"varint,4,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	SourceId        uint32     `protobuf:"varint,5,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	DestinationId   uint32     `protobuf:"varint,6,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"`
	Priority        Priority   `protobuf:"varint,7,opt,name=priority,proto3,enum=rtdex.Priority" json:"priority,omitempty"`
	Timestamp       uint64     `protobuf:"varint,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	PayloadLength   uint32     `protobuf:"varint,9,opt,name=payload_length,json=payloadLength,proto3" json:"payload_length,omitempty"`
	// contains filtered or unexported fields
}

type PacketType int32

type Priority int32

type RTDEXPacket struct {
	Header *PacketHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*RTDEXPacket_JoinRequest
	//	*RTDEXPacket_JoinResponse
	//	*RTDEXPacket_DataRegister
	//	*RTDEXPacket_DataInterest
	//	*RTDEXPacket_DataInterestResponse
	//	*RTDEXPacket_DataContent
	//	*RTDEXPacket_Acknowledgement
	//	*RTDEXPacket_ErrorMessage
	//	*RTDEXPacket_Statistics
	//	*RTDEXPacket_Configuration
	//	*RTDEXPacket_Heartbeat
	Payload isRTDEXPacket_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type RTDEXPacket_Acknowledgement struct {
	Acknowledgement *Acknowledgement `protobuf:"bytes,8,opt,name=acknowledgement,proto3,oneof"`
}

type RTDEXPacket_Configuration struct {
	Configuration *Configuration `protobuf:"bytes,11,opt,name=configuration,proto3,oneof"`
}

type RTDEXPacket_DataContent struct {
	DataContent *DataContent `protobuf:"bytes,7,opt,name=data_content,json=dataContent,proto3,oneof"`
}

type RTDEXPacket_DataInterest struct {
	DataInterest *DataInterest `protobuf:"bytes,5,opt,name=data_interest,json=dataInterest,proto3,oneof"`
}

type RTDEXPacket_DataInterestResponse struct {
	DataInterestResponse *DataInterestResponse `protobuf:"bytes,6,opt,name=data_interest_response,json=dataInterestResponse,proto3,oneof"`
}

type RTDEXPacket_DataRegister struct {
	DataRegister *DataRegister `protobuf:"bytes,4,opt,name=data_register,json=dataRegister,proto3,oneof"`
}

type RTDEXPacket_ErrorMessage struct {
	ErrorMessage *ErrorMessage `protobuf:"bytes,9,opt,name=error_message,json=errorMessage,proto3,oneof"`
}

type RTDEXPacket_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,12,opt,name=heartbeat,proto3,oneof"`
}

type RTDEXPacket_JoinRequest struct {
	JoinRequest *JoinRequest `protobuf:"bytes,2,opt,name=join_request,json=joinRequest,proto3,oneof"`
}

type RTDEXPacket_JoinResponse struct {
	JoinResponse *JoinResponse `protobuf:"bytes,3,opt,name=join_response,json=joinResponse,proto3,oneof"`
}

type RTDEXPacket_Statistics struct {
	Statistics *Statistics `protobuf:"bytes,10,opt,name=statistics,proto3,oneof"`
}

type Statistics struct {
	StationId  uint32 `protobuf:"varint,1,opt,name=station_id,json=stationId,proto3" json:"station_id,omitempty"`
	StatusCode uint32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}