v2

type Config struct {
	// Datadir from core.Config
	Datadir string
	// PayloadRetryDelay initial delay before retrying payload retrieval. Will grow exponentially
	PayloadRetryDelay time.Duration
	// GossipInterval specifies how often (in milliseconds) the node should broadcast its gossip message,
	// so other nodes can compare and synchronize.
	GossipInterval int `koanf:"gossipinterval"`
	// DiagnosticsInterval specifies how often (in milliseconds) the node should broadcast its diagnostics message.
	DiagnosticsInterval int `koanf:"diagnosticsinterval"`
}

type Diagnostics struct {

	// uptime contains the uptime (time since the node started) in seconds.
	Uptime uint32 `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// peerID contains the ID of the node.
	PeerID string `protobuf:"bytes,2,opt,name=peerID,proto3" json:"peerID,omitempty"`
	// peers contains the peer IDs of the node's peers.
	Peers []string `protobuf:"bytes,3,rep,name=peers,proto3" json:"peers,omitempty"`
	// numberOfTransactions contains the total number of transactions on the node's DAG.
	NumberOfTransactions uint32 `protobuf:"varint,4,opt,name=numberOfTransactions,proto3" json:"numberOfTransactions,omitempty"`
	// softwareVersion contains an indication of the software version of the node. It's recommended to use a (Git) commit ID that uniquely resolves to a code revision, alternatively a semantic version could be used (e.g. 1.2.5).
	SoftwareVersion string `protobuf:"bytes,10,opt,name=softwareVersion,proto3" json:"softwareVersion,omitempty"`
	// softwareID contains an identification of the particular Nuts implementation of the node.
	// For open source implementations it's recommended to specify URL to the public, open source repository.
	// Proprietary implementations could specify the product or vendor's name.
	SoftwareID string `protobuf:"bytes,11,opt,name=softwareID,proto3" json:"softwareID,omitempty"`
	// contains filtered or unexported fields
}

type Envelope struct {

	// Types that are valid to be assigned to Message:
	//
	//	*Envelope_Gossip
	//	*Envelope_DiagnosticsBroadcast
	//	*Envelope_State
	//	*Envelope_TransactionListQuery
	//	*Envelope_TransactionRangeQuery
	//	*Envelope_TransactionPayloadQuery
	//	*Envelope_TransactionSet
	//	*Envelope_TransactionList
	//	*Envelope_TransactionPayload
	Message isEnvelope_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type Envelope_DiagnosticsBroadcast struct {
	DiagnosticsBroadcast *Diagnostics `protobuf:"bytes,102,opt,name=diagnosticsBroadcast,proto3,oneof"`
}

type Envelope_Gossip struct {
	// broadcast
	Gossip *Gossip `protobuf:"bytes,101,opt,name=gossip,proto3,oneof"`
}

type Envelope_State struct {
	// request, starts a conversation with a new ID
	State *State `protobuf:"bytes,201,opt,name=state,proto3,oneof"`
}

type Envelope_TransactionList struct {
	TransactionList *TransactionList `protobuf:"bytes,302,opt,name=transactionList,proto3,oneof"`
}

type Envelope_TransactionListQuery struct {
	TransactionListQuery *TransactionListQuery `protobuf:"bytes,202,opt,name=transactionListQuery,proto3,oneof"`
}

type Envelope_TransactionPayload struct {
	TransactionPayload *TransactionPayload `protobuf:"bytes,304,opt,name=transactionPayload,proto3,oneof"`
}

type Envelope_TransactionPayloadQuery struct {
	TransactionPayloadQuery *TransactionPayloadQuery `protobuf:"bytes,204,opt,name=transactionPayloadQuery,proto3,oneof"`
}

type Envelope_TransactionRangeQuery struct {
	TransactionRangeQuery *TransactionRangeQuery `protobuf:"bytes,203,opt,name=transactionRangeQuery,proto3,oneof"`
}

type Envelope_TransactionSet struct {
	// response, contains conversationID from request
	TransactionSet *TransactionSet `protobuf:"bytes,301,opt,name=transactionSet,proto3,oneof"`
}

type Gossip struct {

	// XOR contains the XOR'ed value of all transaction references on the sender's DAG.
	XOR []byte `protobuf:"bytes,1,opt,name=XOR,proto3" json:"XOR,omitempty"`
	// LC contains the highest transaction Lamport Clock value of the sender.
	LC uint32 `protobuf:"varint,2,opt,name=LC,proto3" json:"LC,omitempty"`
	// transactions is a list of transactions recently added to the DAG
	Transactions [][]byte `protobuf:"bytes,3,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ProtocolClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Envelope, Envelope], error)
}

type ProtocolServer interface {
	Stream(grpc.BidiStreamingServer[Envelope, Envelope]) error
}

type Protocol_StreamClient = grpc.BidiStreamingClient[Envelope, Envelope]

type Protocol_StreamServer = grpc.BidiStreamingServer[Envelope, Envelope]

type State struct {

	// conversationID contains the token used to identify the response
	ConversationID []byte `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID,omitempty"`
	// XOR contains the XOR'ed value of ALL transaction references on the sender's DAG.
	XOR []byte `protobuf:"bytes,2,opt,name=XOR,proto3" json:"XOR,omitempty"`
	// LC contains the Lamport Clock value (inclusive) for which the node requests an IBLT
	LC uint32 `protobuf:"varint,3,opt,name=LC,proto3" json:"LC,omitempty"`
	// contains filtered or unexported fields
}

type Transaction struct {

	// data contains the data of the transaction, which is a JWS as specified by RFC004.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// payload contains the payload when it may be attached but wasn't so in the transaction already
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type TransactionList struct {

	// conversationID contains the token used to identify the response
	ConversationID []byte `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID,omitempty"`
	// transactions contains the list of requested transactions. Transactions MUST be sorted by LC value
	Transactions []*Transaction `protobuf:"bytes,2,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// totalMessages is the number of messages that are in the TransactionList sequence with this conversationID
	TotalMessages uint32 `protobuf:"varint,3,opt,name=totalMessages,proto3" json:"totalMessages,omitempty"`
	// messageNumber identifies which message this is in the sequence. Uses 1-based indexing
	MessageNumber uint32 `protobuf:"varint,4,opt,name=messageNumber,proto3" json:"messageNumber,omitempty"`
	// contains filtered or unexported fields
}

type TransactionListQuery struct {

	// conversationID contains the token used to identify the response
	ConversationID []byte `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID,omitempty"`
	// refs is the list of requested transactions by reference
	Refs [][]byte `protobuf:"bytes,2,rep,name=refs,proto3" json:"refs,omitempty"`
	// contains filtered or unexported fields
}

type TransactionPayload struct {

	// conversationID contains the token used to identify the response
	ConversationID []byte `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID,omitempty"`
	// transactionRef contains the reference to the transaction which' payload was requested.
	TransactionRef []byte `protobuf:"bytes,2,opt,name=transactionRef,proto3" json:"transactionRef,omitempty"`
	// data contains the actual payload.
	Data []byte `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type TransactionPayloadQuery struct {

	// conversationID contains the token used to identify the response
	ConversationID []byte `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID,omitempty"`
	// transactionRef contains the reference (hash) of the transaction, which payload the node would like to receive, as specified by RFC004.
	TransactionRef []byte `protobuf:"bytes,2,opt,name=transactionRef,proto3" json:"transactionRef,omitempty"`
	// contains filtered or unexported fields
}

type TransactionRangeQuery struct {

	// conversationID contains the token used to identify the response
	ConversationID []byte `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID,omitempty"`
	// start indicates the start of the requested Lamport Clock range (inclusive)
	Start uint32 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	// end indicates the end of the requested Lamport Clock range (exclusive)
	End uint32 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

type TransactionSet struct {

	// conversationID contains the token used to identify the response
	ConversationID []byte `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID,omitempty"`
	// LCReq contains the LC value that was sent in the State message
	LCReq uint32 `protobuf:"varint,2,opt,name=LCReq,proto3" json:"LCReq,omitempty"`
	// LC contains the highest transaction Lamport Clock value from the sender of this message.
	LC uint32 `protobuf:"varint,3,opt,name=LC,proto3" json:"LC,omitempty"`
	// IBLT contains the serialized IBLT. The first byte indicates the serialization format of the IBLT.
	IBLT []byte `protobuf:"bytes,4,opt,name=IBLT,proto3" json:"IBLT,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedProtocolServer struct{}

type UnsafeProtocolServer interface {
	// contains filtered or unexported methods
}