write_target

package
v0.0.0-...-29137c7 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_write_accepted_proto protoreflect.FileDescriptor
View Source 
var File_write_confirmed_proto protoreflect.FileDescriptor
View Source 
var File_write_error_proto protoreflect.FileDescriptor
View Source 
var File_write_initiated_proto protoreflect.FileDescriptor
View Source 
var File_write_sent_proto protoreflect.FileDescriptor
View Source 
var File_write_skipped_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Metrics 

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

Define a new struct for metrics

func NewMetrics 

func NewMetrics() (*Metrics, error)

func (*Metrics) OnWriteConfirmed 

func (m *Metrics) OnWriteConfirmed(ctx context.Context, msg *WriteConfirmed, attrKVs ...any) error

func (*Metrics) OnWriteError 

func (m *Metrics) OnWriteError(ctx context.Context, msg *WriteError, attrKVs ...any) error

func (*Metrics) OnWriteInitiated 

func (m *Metrics) OnWriteInitiated(ctx context.Context, msg *WriteInitiated, attrKVs ...any) error

func (*Metrics) OnWriteSent 

func (m *Metrics) OnWriteSent(ctx context.Context, msg *WriteSent, attrKVs ...any) error

type WriteAccepted 

type WriteAccepted struct {
	Node      string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Forwarder string `protobuf:"bytes,2,opt,name=forwarder,proto3" json:"forwarder,omitempty"`
	Receiver  string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Report Info
	ReportId uint32 `protobuf:"varint,4,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
	// When was the transaction accepted on-chain
	BlockHash      string `protobuf:"bytes,6,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	BlockHeight    string `protobuf:"bytes,7,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockTimestamp uint64 `protobuf:"varint,8,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"`
	// Transaction data - info about the tx that mained the event (optional)
	TxId       string `protobuf:"bytes,10,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // TXM ref
	TxHash     string `protobuf:"bytes,11,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	TxSender   string `protobuf:"bytes,12,opt,name=tx_sender,json=txSender,proto3" json:"tx_sender,omitempty"`
	TxReceiver string `protobuf:"bytes,13,opt,name=tx_receiver,json=txReceiver,proto3" json:"tx_receiver,omitempty"`
	TxStatus   string `protobuf:"bytes,14,opt,name=tx_status,json=txStatus,proto3" json:"tx_status,omitempty"`
	// [Execution Context]
	// TODO: replace with a proto reference once supported
	// Execution Context - Source
	MetaSourceId string `protobuf:"bytes,20,opt,name=meta_source_id,json=metaSourceId,proto3" json:"meta_source_id,omitempty"`
	// Execution Context - Chain
	MetaChainFamilyName string `protobuf:"bytes,21,opt,name=meta_chain_family_name,json=metaChainFamilyName,proto3" json:"meta_chain_family_name,omitempty"`
	MetaChainId         string `protobuf:"bytes,22,opt,name=meta_chain_id,json=metaChainId,proto3" json:"meta_chain_id,omitempty"`
	MetaNetworkName     string `protobuf:"bytes,23,opt,name=meta_network_name,json=metaNetworkName,proto3" json:"meta_network_name,omitempty"`
	MetaNetworkNameFull string `protobuf:"bytes,24,opt,name=meta_network_name_full,json=metaNetworkNameFull,proto3" json:"meta_network_name_full,omitempty"`
	// Execution Context - Workflow (capabilities.RequestMetadata)
	MetaWorkflowId               string `protobuf:"bytes,25,opt,name=meta_workflow_id,json=metaWorkflowId,proto3" json:"meta_workflow_id,omitempty"`
	MetaWorkflowOwner            string `protobuf:"bytes,26,opt,name=meta_workflow_owner,json=metaWorkflowOwner,proto3" json:"meta_workflow_owner,omitempty"`
	MetaWorkflowExecutionId      string `` /* 135-byte string literal not displayed */
	MetaWorkflowName             string `protobuf:"bytes,28,opt,name=meta_workflow_name,json=metaWorkflowName,proto3" json:"meta_workflow_name,omitempty"`
	MetaWorkflowDonId            uint32 `protobuf:"varint,29,opt,name=meta_workflow_don_id,json=metaWorkflowDonId,proto3" json:"meta_workflow_don_id,omitempty"`
	MetaWorkflowDonConfigVersion uint32 `` /* 153-byte string literal not displayed */
	MetaReferenceId              string `protobuf:"bytes,31,opt,name=meta_reference_id,json=metaReferenceId,proto3" json:"meta_reference_id,omitempty"`
	// Execution Context - Capability
	MetaCapabilityType           string `protobuf:"bytes,32,opt,name=meta_capability_type,json=metaCapabilityType,proto3" json:"meta_capability_type,omitempty"`
	MetaCapabilityId             string `protobuf:"bytes,33,opt,name=meta_capability_id,json=metaCapabilityId,proto3" json:"meta_capability_id,omitempty"`
	MetaCapabilityTimestampStart uint64 `` /* 151-byte string literal not displayed */
	MetaCapabilityTimestampEmit  uint64 `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

WT sent a transaction and it was accepted on-chain

Notice: we publish txId (TXM ref) and txHash (in the future should be available here)

func (*WriteAccepted) Descriptor deprecated 

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

Deprecated: Use WriteAccepted.ProtoReflect.Descriptor instead.

func (*WriteAccepted) GetBlockHash 

func (x *WriteAccepted) GetBlockHash() string

func (*WriteAccepted) GetBlockHeight 

func (x *WriteAccepted) GetBlockHeight() string

func (*WriteAccepted) GetBlockTimestamp 

func (x *WriteAccepted) GetBlockTimestamp() uint64

func (*WriteAccepted) GetForwarder 

func (x *WriteAccepted) GetForwarder() string

func (*WriteAccepted) GetMetaCapabilityId 

func (x *WriteAccepted) GetMetaCapabilityId() string

func (*WriteAccepted) GetMetaCapabilityTimestampEmit 

func (x *WriteAccepted) GetMetaCapabilityTimestampEmit() uint64

func (*WriteAccepted) GetMetaCapabilityTimestampStart 

func (x *WriteAccepted) GetMetaCapabilityTimestampStart() uint64

func (*WriteAccepted) GetMetaCapabilityType 

func (x *WriteAccepted) GetMetaCapabilityType() string

func (*WriteAccepted) GetMetaChainFamilyName 

func (x *WriteAccepted) GetMetaChainFamilyName() string

func (*WriteAccepted) GetMetaChainId 

func (x *WriteAccepted) GetMetaChainId() string

func (*WriteAccepted) GetMetaNetworkName 

func (x *WriteAccepted) GetMetaNetworkName() string

func (*WriteAccepted) GetMetaNetworkNameFull 

func (x *WriteAccepted) GetMetaNetworkNameFull() string

func (*WriteAccepted) GetMetaReferenceId 

func (x *WriteAccepted) GetMetaReferenceId() string

func (*WriteAccepted) GetMetaSourceId 

func (x *WriteAccepted) GetMetaSourceId() string

func (*WriteAccepted) GetMetaWorkflowDonConfigVersion 

func (x *WriteAccepted) GetMetaWorkflowDonConfigVersion() uint32

func (*WriteAccepted) GetMetaWorkflowDonId 

func (x *WriteAccepted) GetMetaWorkflowDonId() uint32

func (*WriteAccepted) GetMetaWorkflowExecutionId 

func (x *WriteAccepted) GetMetaWorkflowExecutionId() string

func (*WriteAccepted) GetMetaWorkflowId 

func (x *WriteAccepted) GetMetaWorkflowId() string

func (*WriteAccepted) GetMetaWorkflowName 

func (x *WriteAccepted) GetMetaWorkflowName() string

func (*WriteAccepted) GetMetaWorkflowOwner 

func (x *WriteAccepted) GetMetaWorkflowOwner() string

func (*WriteAccepted) GetNode 

func (x *WriteAccepted) GetNode() string

func (*WriteAccepted) GetReceiver 

func (x *WriteAccepted) GetReceiver() string

func (*WriteAccepted) GetReportId 

func (x *WriteAccepted) GetReportId() uint32

func (*WriteAccepted) GetTxHash 

func (x *WriteAccepted) GetTxHash() string

func (*WriteAccepted) GetTxId 

func (x *WriteAccepted) GetTxId() string

func (*WriteAccepted) GetTxReceiver 

func (x *WriteAccepted) GetTxReceiver() string

func (*WriteAccepted) GetTxSender 

func (x *WriteAccepted) GetTxSender() string

func (*WriteAccepted) GetTxStatus 

func (x *WriteAccepted) GetTxStatus() string

func (*WriteAccepted) ProtoMessage 

func (*WriteAccepted) ProtoMessage()

func (*WriteAccepted) ProtoReflect 

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

func (*WriteAccepted) Reset 

func (x *WriteAccepted) Reset()

func (*WriteAccepted) String 

func (x *WriteAccepted) String() string

type WriteConfirmed 

type WriteConfirmed struct {
	Node      string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Forwarder string `protobuf:"bytes,2,opt,name=forwarder,proto3" json:"forwarder,omitempty"`
	Receiver  string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Report Info
	ReportId      uint32 `protobuf:"varint,4,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
	ReportContext []byte `protobuf:"bytes,5,opt,name=report_context,json=reportContext,proto3" json:"report_context,omitempty"`
	Report        []byte `protobuf:"bytes,6,opt,name=report,proto3" json:"report,omitempty"`
	SignersNum    uint32 `protobuf:"varint,7,opt,name=signers_num,json=signersNum,proto3" json:"signers_num,omitempty"`
	// When was the report confirmed on-chain
	BlockHash      string `protobuf:"bytes,9,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	BlockHeight    string `protobuf:"bytes,10,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockTimestamp uint64 `protobuf:"varint,11,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"`
	// Transmission Info
	Transmitter string `protobuf:"bytes,12,opt,name=transmitter,proto3" json:"transmitter,omitempty"`
	Success     bool   `protobuf:"varint,13,opt,name=success,proto3" json:"success,omitempty"` // TODO: what about EVM's TransmissionInfo parity?
	// [Execution Context]
	// TODO: replace with a proto reference once supported
	// Execution Context - Source
	MetaSourceId string `protobuf:"bytes,20,opt,name=meta_source_id,json=metaSourceId,proto3" json:"meta_source_id,omitempty"`
	// Execution Context - Chain
	MetaChainFamilyName string `protobuf:"bytes,21,opt,name=meta_chain_family_name,json=metaChainFamilyName,proto3" json:"meta_chain_family_name,omitempty"`
	MetaChainId         string `protobuf:"bytes,22,opt,name=meta_chain_id,json=metaChainId,proto3" json:"meta_chain_id,omitempty"`
	MetaNetworkName     string `protobuf:"bytes,23,opt,name=meta_network_name,json=metaNetworkName,proto3" json:"meta_network_name,omitempty"`
	MetaNetworkNameFull string `protobuf:"bytes,24,opt,name=meta_network_name_full,json=metaNetworkNameFull,proto3" json:"meta_network_name_full,omitempty"`
	// Execution Context - Workflow (capabilities.RequestMetadata)
	MetaWorkflowId               string `protobuf:"bytes,25,opt,name=meta_workflow_id,json=metaWorkflowId,proto3" json:"meta_workflow_id,omitempty"`
	MetaWorkflowOwner            string `protobuf:"bytes,26,opt,name=meta_workflow_owner,json=metaWorkflowOwner,proto3" json:"meta_workflow_owner,omitempty"`
	MetaWorkflowExecutionId      string `` /* 135-byte string literal not displayed */
	MetaWorkflowName             string `protobuf:"bytes,28,opt,name=meta_workflow_name,json=metaWorkflowName,proto3" json:"meta_workflow_name,omitempty"`
	MetaWorkflowDonId            uint32 `protobuf:"varint,29,opt,name=meta_workflow_don_id,json=metaWorkflowDonId,proto3" json:"meta_workflow_don_id,omitempty"`
	MetaWorkflowDonConfigVersion uint32 `` /* 153-byte string literal not displayed */
	MetaReferenceId              string `protobuf:"bytes,31,opt,name=meta_reference_id,json=metaReferenceId,proto3" json:"meta_reference_id,omitempty"`
	// Execution Context - Capability
	MetaCapabilityType           string `protobuf:"bytes,32,opt,name=meta_capability_type,json=metaCapabilityType,proto3" json:"meta_capability_type,omitempty"`
	MetaCapabilityId             string `protobuf:"bytes,33,opt,name=meta_capability_id,json=metaCapabilityId,proto3" json:"meta_capability_id,omitempty"`
	MetaCapabilityTimestampStart uint64 `` /* 151-byte string literal not displayed */
	MetaCapabilityTimestampEmit  uint64 `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

WT confirmed the report was successfully written on-chain

func (*WriteConfirmed) Attributes 

func (m *WriteConfirmed) Attributes() []attribute.KeyValue

Attributes returns the attributes for the WriteConfirmed message to be used in metrics

func (*WriteConfirmed) Descriptor deprecated 

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

Deprecated: Use WriteConfirmed.ProtoReflect.Descriptor instead.

func (*WriteConfirmed) GetBlockHash 

func (x *WriteConfirmed) GetBlockHash() string

func (*WriteConfirmed) GetBlockHeight 

func (x *WriteConfirmed) GetBlockHeight() string

func (*WriteConfirmed) GetBlockTimestamp 

func (x *WriteConfirmed) GetBlockTimestamp() uint64

func (*WriteConfirmed) GetForwarder 

func (x *WriteConfirmed) GetForwarder() string

func (*WriteConfirmed) GetMetaCapabilityId 

func (x *WriteConfirmed) GetMetaCapabilityId() string

func (*WriteConfirmed) GetMetaCapabilityTimestampEmit 

func (x *WriteConfirmed) GetMetaCapabilityTimestampEmit() uint64

func (*WriteConfirmed) GetMetaCapabilityTimestampStart 

func (x *WriteConfirmed) GetMetaCapabilityTimestampStart() uint64

func (*WriteConfirmed) GetMetaCapabilityType 

func (x *WriteConfirmed) GetMetaCapabilityType() string

func (*WriteConfirmed) GetMetaChainFamilyName 

func (x *WriteConfirmed) GetMetaChainFamilyName() string

func (*WriteConfirmed) GetMetaChainId 

func (x *WriteConfirmed) GetMetaChainId() string

func (*WriteConfirmed) GetMetaNetworkName 

func (x *WriteConfirmed) GetMetaNetworkName() string

func (*WriteConfirmed) GetMetaNetworkNameFull 

func (x *WriteConfirmed) GetMetaNetworkNameFull() string

func (*WriteConfirmed) GetMetaReferenceId 

func (x *WriteConfirmed) GetMetaReferenceId() string

func (*WriteConfirmed) GetMetaSourceId 

func (x *WriteConfirmed) GetMetaSourceId() string

func (*WriteConfirmed) GetMetaWorkflowDonConfigVersion 

func (x *WriteConfirmed) GetMetaWorkflowDonConfigVersion() uint32

func (*WriteConfirmed) GetMetaWorkflowDonId 

func (x *WriteConfirmed) GetMetaWorkflowDonId() uint32

func (*WriteConfirmed) GetMetaWorkflowExecutionId 

func (x *WriteConfirmed) GetMetaWorkflowExecutionId() string

func (*WriteConfirmed) GetMetaWorkflowId 

func (x *WriteConfirmed) GetMetaWorkflowId() string

func (*WriteConfirmed) GetMetaWorkflowName 

func (x *WriteConfirmed) GetMetaWorkflowName() string

func (*WriteConfirmed) GetMetaWorkflowOwner 

func (x *WriteConfirmed) GetMetaWorkflowOwner() string

func (*WriteConfirmed) GetNode 

func (x *WriteConfirmed) GetNode() string

func (*WriteConfirmed) GetReceiver 

func (x *WriteConfirmed) GetReceiver() string

func (*WriteConfirmed) GetReport 

func (x *WriteConfirmed) GetReport() []byte

func (*WriteConfirmed) GetReportContext 

func (x *WriteConfirmed) GetReportContext() []byte

func (*WriteConfirmed) GetReportId 

func (x *WriteConfirmed) GetReportId() uint32

func (*WriteConfirmed) GetSignersNum 

func (x *WriteConfirmed) GetSignersNum() uint32

func (*WriteConfirmed) GetSuccess 

func (x *WriteConfirmed) GetSuccess() bool

func (*WriteConfirmed) GetTransmitter 

func (x *WriteConfirmed) GetTransmitter() string

func (*WriteConfirmed) ProtoMessage 

func (*WriteConfirmed) ProtoMessage()

func (*WriteConfirmed) ProtoReflect 

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

func (*WriteConfirmed) Reset 

func (x *WriteConfirmed) Reset()

func (*WriteConfirmed) String 

func (x *WriteConfirmed) String() string

type WriteError 

type WriteError struct {
	Code      uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Summary   string `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
	Cause     string `protobuf:"bytes,3,opt,name=cause,proto3" json:"cause,omitempty"`
	Node      string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	Forwarder string `protobuf:"bytes,5,opt,name=forwarder,proto3" json:"forwarder,omitempty"`
	Receiver  string `protobuf:"bytes,6,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Report Info
	ReportId uint32 `protobuf:"varint,7,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
	// [Execution Context]
	// TODO: replace with a proto reference once supported
	// Execution Context - Source
	MetaSourceId string `protobuf:"bytes,20,opt,name=meta_source_id,json=metaSourceId,proto3" json:"meta_source_id,omitempty"`
	// Execution Context - Chain
	MetaChainFamilyName string `protobuf:"bytes,21,opt,name=meta_chain_family_name,json=metaChainFamilyName,proto3" json:"meta_chain_family_name,omitempty"`
	MetaChainId         string `protobuf:"bytes,22,opt,name=meta_chain_id,json=metaChainId,proto3" json:"meta_chain_id,omitempty"`
	MetaNetworkName     string `protobuf:"bytes,23,opt,name=meta_network_name,json=metaNetworkName,proto3" json:"meta_network_name,omitempty"`
	MetaNetworkNameFull string `protobuf:"bytes,24,opt,name=meta_network_name_full,json=metaNetworkNameFull,proto3" json:"meta_network_name_full,omitempty"`
	// Execution Context - Workflow (capabilities.RequestMetadata)
	MetaWorkflowId               string `protobuf:"bytes,25,opt,name=meta_workflow_id,json=metaWorkflowId,proto3" json:"meta_workflow_id,omitempty"`
	MetaWorkflowOwner            string `protobuf:"bytes,26,opt,name=meta_workflow_owner,json=metaWorkflowOwner,proto3" json:"meta_workflow_owner,omitempty"`
	MetaWorkflowExecutionId      string `` /* 135-byte string literal not displayed */
	MetaWorkflowName             string `protobuf:"bytes,28,opt,name=meta_workflow_name,json=metaWorkflowName,proto3" json:"meta_workflow_name,omitempty"`
	MetaWorkflowDonId            uint32 `protobuf:"varint,29,opt,name=meta_workflow_don_id,json=metaWorkflowDonId,proto3" json:"meta_workflow_don_id,omitempty"`
	MetaWorkflowDonConfigVersion uint32 `` /* 153-byte string literal not displayed */
	MetaReferenceId              string `protobuf:"bytes,31,opt,name=meta_reference_id,json=metaReferenceId,proto3" json:"meta_reference_id,omitempty"`
	// Execution Context - Capability
	MetaCapabilityType           string `protobuf:"bytes,32,opt,name=meta_capability_type,json=metaCapabilityType,proto3" json:"meta_capability_type,omitempty"`
	MetaCapabilityId             string `protobuf:"bytes,33,opt,name=meta_capability_id,json=metaCapabilityId,proto3" json:"meta_capability_id,omitempty"`
	MetaCapabilityTimestampStart uint64 `` /* 151-byte string literal not displayed */
	MetaCapabilityTimestampEmit  uint64 `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

WT errored while processing write request

func (*WriteError) AsError 

func (e *WriteError) AsError() error

AsError returns the WriteError message as an (Go) error

func (*WriteError) Attributes 

func (m *WriteError) Attributes() []attribute.KeyValue

Attributes returns the attributes for the WriteError message to be used in metrics

func (*WriteError) Descriptor deprecated 

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

Deprecated: Use WriteError.ProtoReflect.Descriptor instead.

func (*WriteError) GetCause 

func (x *WriteError) GetCause() string

func (*WriteError) GetCode 

func (x *WriteError) GetCode() uint32

func (*WriteError) GetForwarder 

func (x *WriteError) GetForwarder() string

func (*WriteError) GetMetaCapabilityId 

func (x *WriteError) GetMetaCapabilityId() string

func (*WriteError) GetMetaCapabilityTimestampEmit 

func (x *WriteError) GetMetaCapabilityTimestampEmit() uint64

func (*WriteError) GetMetaCapabilityTimestampStart 

func (x *WriteError) GetMetaCapabilityTimestampStart() uint64

func (*WriteError) GetMetaCapabilityType 

func (x *WriteError) GetMetaCapabilityType() string

func (*WriteError) GetMetaChainFamilyName 

func (x *WriteError) GetMetaChainFamilyName() string

func (*WriteError) GetMetaChainId 

func (x *WriteError) GetMetaChainId() string

func (*WriteError) GetMetaNetworkName 

func (x *WriteError) GetMetaNetworkName() string

func (*WriteError) GetMetaNetworkNameFull 

func (x *WriteError) GetMetaNetworkNameFull() string

func (*WriteError) GetMetaReferenceId 

func (x *WriteError) GetMetaReferenceId() string

func (*WriteError) GetMetaSourceId 

func (x *WriteError) GetMetaSourceId() string

func (*WriteError) GetMetaWorkflowDonConfigVersion 

func (x *WriteError) GetMetaWorkflowDonConfigVersion() uint32

func (*WriteError) GetMetaWorkflowDonId 

func (x *WriteError) GetMetaWorkflowDonId() uint32

func (*WriteError) GetMetaWorkflowExecutionId 

func (x *WriteError) GetMetaWorkflowExecutionId() string

func (*WriteError) GetMetaWorkflowId 

func (x *WriteError) GetMetaWorkflowId() string

func (*WriteError) GetMetaWorkflowName 

func (x *WriteError) GetMetaWorkflowName() string

func (*WriteError) GetMetaWorkflowOwner 

func (x *WriteError) GetMetaWorkflowOwner() string

func (*WriteError) GetNode 

func (x *WriteError) GetNode() string

func (*WriteError) GetReceiver 

func (x *WriteError) GetReceiver() string

func (*WriteError) GetReportId 

func (x *WriteError) GetReportId() uint32

func (*WriteError) GetSummary 

func (x *WriteError) GetSummary() string

func (*WriteError) ProtoMessage 

func (*WriteError) ProtoMessage()

func (*WriteError) ProtoReflect 

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

func (*WriteError) Reset 

func (x *WriteError) Reset()

func (*WriteError) String 

func (x *WriteError) String() string

type WriteInitiated 

type WriteInitiated struct {
	Node      string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Forwarder string `protobuf:"bytes,2,opt,name=forwarder,proto3" json:"forwarder,omitempty"`
	Receiver  string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Report Info
	ReportId uint32 `protobuf:"varint,4,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
	// [Execution Context]
	// TODO: replace with a proto reference once supported
	// Execution Context - Source
	MetaSourceId string `protobuf:"bytes,20,opt,name=meta_source_id,json=metaSourceId,proto3" json:"meta_source_id,omitempty"`
	// Execution Context - Chain
	MetaChainFamilyName string `protobuf:"bytes,21,opt,name=meta_chain_family_name,json=metaChainFamilyName,proto3" json:"meta_chain_family_name,omitempty"`
	MetaChainId         string `protobuf:"bytes,22,opt,name=meta_chain_id,json=metaChainId,proto3" json:"meta_chain_id,omitempty"`
	MetaNetworkName     string `protobuf:"bytes,23,opt,name=meta_network_name,json=metaNetworkName,proto3" json:"meta_network_name,omitempty"`
	MetaNetworkNameFull string `protobuf:"bytes,24,opt,name=meta_network_name_full,json=metaNetworkNameFull,proto3" json:"meta_network_name_full,omitempty"`
	// Execution Context - Workflow (capabilities.RequestMetadata)
	MetaWorkflowId               string `protobuf:"bytes,25,opt,name=meta_workflow_id,json=metaWorkflowId,proto3" json:"meta_workflow_id,omitempty"`
	MetaWorkflowOwner            string `protobuf:"bytes,26,opt,name=meta_workflow_owner,json=metaWorkflowOwner,proto3" json:"meta_workflow_owner,omitempty"`
	MetaWorkflowExecutionId      string `` /* 135-byte string literal not displayed */
	MetaWorkflowName             string `protobuf:"bytes,28,opt,name=meta_workflow_name,json=metaWorkflowName,proto3" json:"meta_workflow_name,omitempty"`
	MetaWorkflowDonId            uint32 `protobuf:"varint,29,opt,name=meta_workflow_don_id,json=metaWorkflowDonId,proto3" json:"meta_workflow_don_id,omitempty"`
	MetaWorkflowDonConfigVersion uint32 `` /* 153-byte string literal not displayed */
	MetaReferenceId              string `protobuf:"bytes,31,opt,name=meta_reference_id,json=metaReferenceId,proto3" json:"meta_reference_id,omitempty"`
	// Execution Context - Capability
	MetaCapabilityType           string `protobuf:"bytes,32,opt,name=meta_capability_type,json=metaCapabilityType,proto3" json:"meta_capability_type,omitempty"`
	MetaCapabilityId             string `protobuf:"bytes,33,opt,name=meta_capability_id,json=metaCapabilityId,proto3" json:"meta_capability_id,omitempty"`
	MetaCapabilityTimestampStart uint64 `` /* 151-byte string literal not displayed */
	MetaCapabilityTimestampEmit  uint64 `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

WT initiated the processing of the write request

func (*WriteInitiated) Attributes 

func (m *WriteInitiated) Attributes() []attribute.KeyValue

Attributes returns the attributes for the WriteInitiated message to be used in metrics

func (*WriteInitiated) Descriptor deprecated 

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

Deprecated: Use WriteInitiated.ProtoReflect.Descriptor instead.

func (*WriteInitiated) GetForwarder 

func (x *WriteInitiated) GetForwarder() string

func (*WriteInitiated) GetMetaCapabilityId 

func (x *WriteInitiated) GetMetaCapabilityId() string

func (*WriteInitiated) GetMetaCapabilityTimestampEmit 

func (x *WriteInitiated) GetMetaCapabilityTimestampEmit() uint64

func (*WriteInitiated) GetMetaCapabilityTimestampStart 

func (x *WriteInitiated) GetMetaCapabilityTimestampStart() uint64

func (*WriteInitiated) GetMetaCapabilityType 

func (x *WriteInitiated) GetMetaCapabilityType() string

func (*WriteInitiated) GetMetaChainFamilyName 

func (x *WriteInitiated) GetMetaChainFamilyName() string

func (*WriteInitiated) GetMetaChainId 

func (x *WriteInitiated) GetMetaChainId() string

func (*WriteInitiated) GetMetaNetworkName 

func (x *WriteInitiated) GetMetaNetworkName() string

func (*WriteInitiated) GetMetaNetworkNameFull 

func (x *WriteInitiated) GetMetaNetworkNameFull() string

func (*WriteInitiated) GetMetaReferenceId 

func (x *WriteInitiated) GetMetaReferenceId() string

func (*WriteInitiated) GetMetaSourceId 

func (x *WriteInitiated) GetMetaSourceId() string

func (*WriteInitiated) GetMetaWorkflowDonConfigVersion 

func (x *WriteInitiated) GetMetaWorkflowDonConfigVersion() uint32

func (*WriteInitiated) GetMetaWorkflowDonId 

func (x *WriteInitiated) GetMetaWorkflowDonId() uint32

func (*WriteInitiated) GetMetaWorkflowExecutionId 

func (x *WriteInitiated) GetMetaWorkflowExecutionId() string

func (*WriteInitiated) GetMetaWorkflowId 

func (x *WriteInitiated) GetMetaWorkflowId() string

func (*WriteInitiated) GetMetaWorkflowName 

func (x *WriteInitiated) GetMetaWorkflowName() string

func (*WriteInitiated) GetMetaWorkflowOwner 

func (x *WriteInitiated) GetMetaWorkflowOwner() string

func (*WriteInitiated) GetNode 

func (x *WriteInitiated) GetNode() string

func (*WriteInitiated) GetReceiver 

func (x *WriteInitiated) GetReceiver() string

func (*WriteInitiated) GetReportId 

func (x *WriteInitiated) GetReportId() uint32

func (*WriteInitiated) ProtoMessage 

func (*WriteInitiated) ProtoMessage()

func (*WriteInitiated) ProtoReflect 

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

func (*WriteInitiated) Reset 

func (x *WriteInitiated) Reset()

func (*WriteInitiated) String 

func (x *WriteInitiated) String() string

type WriteSent 

type WriteSent struct {
	Node      string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Forwarder string `protobuf:"bytes,2,opt,name=forwarder,proto3" json:"forwarder,omitempty"`
	Receiver  string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Report Info
	ReportId uint32 `protobuf:"varint,4,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
	// Transaction ID - tx reference as created by the WT, to be used for tracking TXM execution
	TxId string `protobuf:"bytes,5,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// When was the transaction submitted
	BlockHash      string `protobuf:"bytes,7,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	BlockHeight    string `protobuf:"bytes,8,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockTimestamp uint64 `protobuf:"varint,9,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"`
	// [Execution Context]
	// TODO: replace with a proto reference once supported
	// Execution Context - Source
	MetaSourceId string `protobuf:"bytes,20,opt,name=meta_source_id,json=metaSourceId,proto3" json:"meta_source_id,omitempty"`
	// Execution Context - Chain
	MetaChainFamilyName string `protobuf:"bytes,21,opt,name=meta_chain_family_name,json=metaChainFamilyName,proto3" json:"meta_chain_family_name,omitempty"`
	MetaChainId         string `protobuf:"bytes,22,opt,name=meta_chain_id,json=metaChainId,proto3" json:"meta_chain_id,omitempty"`
	MetaNetworkName     string `protobuf:"bytes,23,opt,name=meta_network_name,json=metaNetworkName,proto3" json:"meta_network_name,omitempty"`
	MetaNetworkNameFull string `protobuf:"bytes,24,opt,name=meta_network_name_full,json=metaNetworkNameFull,proto3" json:"meta_network_name_full,omitempty"`
	// Execution Context - Workflow (capabilities.RequestMetadata)
	MetaWorkflowId               string `protobuf:"bytes,25,opt,name=meta_workflow_id,json=metaWorkflowId,proto3" json:"meta_workflow_id,omitempty"`
	MetaWorkflowOwner            string `protobuf:"bytes,26,opt,name=meta_workflow_owner,json=metaWorkflowOwner,proto3" json:"meta_workflow_owner,omitempty"`
	MetaWorkflowExecutionId      string `` /* 135-byte string literal not displayed */
	MetaWorkflowName             string `protobuf:"bytes,28,opt,name=meta_workflow_name,json=metaWorkflowName,proto3" json:"meta_workflow_name,omitempty"`
	MetaWorkflowDonId            uint32 `protobuf:"varint,29,opt,name=meta_workflow_don_id,json=metaWorkflowDonId,proto3" json:"meta_workflow_don_id,omitempty"`
	MetaWorkflowDonConfigVersion uint32 `` /* 153-byte string literal not displayed */
	MetaReferenceId              string `protobuf:"bytes,31,opt,name=meta_reference_id,json=metaReferenceId,proto3" json:"meta_reference_id,omitempty"`
	// Execution Context - Capability
	MetaCapabilityType           string `protobuf:"bytes,32,opt,name=meta_capability_type,json=metaCapabilityType,proto3" json:"meta_capability_type,omitempty"`
	MetaCapabilityId             string `protobuf:"bytes,33,opt,name=meta_capability_id,json=metaCapabilityId,proto3" json:"meta_capability_id,omitempty"`
	MetaCapabilityTimestampStart uint64 `` /* 151-byte string literal not displayed */
	MetaCapabilityTimestampEmit  uint64 `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

WT sent a transaction on-chain

Notice: we publish txId (TXM ref) vs. txHash (N/A here)

func (*WriteSent) Attributes 

func (m *WriteSent) Attributes() []attribute.KeyValue

Attributes returns the attributes for the WriteSent message to be used in metrics

func (*WriteSent) Descriptor deprecated 

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

Deprecated: Use WriteSent.ProtoReflect.Descriptor instead.

func (*WriteSent) GetBlockHash 

func (x *WriteSent) GetBlockHash() string

func (*WriteSent) GetBlockHeight 

func (x *WriteSent) GetBlockHeight() string

func (*WriteSent) GetBlockTimestamp 

func (x *WriteSent) GetBlockTimestamp() uint64

func (*WriteSent) GetForwarder 

func (x *WriteSent) GetForwarder() string

func (*WriteSent) GetMetaCapabilityId 

func (x *WriteSent) GetMetaCapabilityId() string

func (*WriteSent) GetMetaCapabilityTimestampEmit 

func (x *WriteSent) GetMetaCapabilityTimestampEmit() uint64

func (*WriteSent) GetMetaCapabilityTimestampStart 

func (x *WriteSent) GetMetaCapabilityTimestampStart() uint64

func (*WriteSent) GetMetaCapabilityType 

func (x *WriteSent) GetMetaCapabilityType() string

func (*WriteSent) GetMetaChainFamilyName 

func (x *WriteSent) GetMetaChainFamilyName() string

func (*WriteSent) GetMetaChainId 

func (x *WriteSent) GetMetaChainId() string

func (*WriteSent) GetMetaNetworkName 

func (x *WriteSent) GetMetaNetworkName() string

func (*WriteSent) GetMetaNetworkNameFull 

func (x *WriteSent) GetMetaNetworkNameFull() string

func (*WriteSent) GetMetaReferenceId 

func (x *WriteSent) GetMetaReferenceId() string

func (*WriteSent) GetMetaSourceId 

func (x *WriteSent) GetMetaSourceId() string

func (*WriteSent) GetMetaWorkflowDonConfigVersion 

func (x *WriteSent) GetMetaWorkflowDonConfigVersion() uint32

func (*WriteSent) GetMetaWorkflowDonId 

func (x *WriteSent) GetMetaWorkflowDonId() uint32

func (*WriteSent) GetMetaWorkflowExecutionId 

func (x *WriteSent) GetMetaWorkflowExecutionId() string

func (*WriteSent) GetMetaWorkflowId 

func (x *WriteSent) GetMetaWorkflowId() string

func (*WriteSent) GetMetaWorkflowName 

func (x *WriteSent) GetMetaWorkflowName() string

func (*WriteSent) GetMetaWorkflowOwner 

func (x *WriteSent) GetMetaWorkflowOwner() string

func (*WriteSent) GetNode 

func (x *WriteSent) GetNode() string

func (*WriteSent) GetReceiver 

func (x *WriteSent) GetReceiver() string

func (*WriteSent) GetReportId 

func (x *WriteSent) GetReportId() uint32

func (*WriteSent) GetTxId 

func (x *WriteSent) GetTxId() string

func (*WriteSent) ProtoMessage 

func (*WriteSent) ProtoMessage()

func (*WriteSent) ProtoReflect 

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

func (*WriteSent) Reset 

func (x *WriteSent) Reset()

func (*WriteSent) String 

func (x *WriteSent) String() string

type WriteSkipped 

type WriteSkipped struct {
	Node      string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Forwarder string `protobuf:"bytes,2,opt,name=forwarder,proto3" json:"forwarder,omitempty"`
	Receiver  string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
	ReportId  uint32 `protobuf:"varint,4,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
	Reason    string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	// [Execution Context]
	// TODO: replace with a proto reference once supported
	// Execution Context - Source
	MetaSourceId string `protobuf:"bytes,20,opt,name=meta_source_id,json=metaSourceId,proto3" json:"meta_source_id,omitempty"`
	// Execution Context - Chain
	MetaChainFamilyName string `protobuf:"bytes,21,opt,name=meta_chain_family_name,json=metaChainFamilyName,proto3" json:"meta_chain_family_name,omitempty"`
	MetaChainId         string `protobuf:"bytes,22,opt,name=meta_chain_id,json=metaChainId,proto3" json:"meta_chain_id,omitempty"`
	MetaNetworkName     string `protobuf:"bytes,23,opt,name=meta_network_name,json=metaNetworkName,proto3" json:"meta_network_name,omitempty"`
	MetaNetworkNameFull string `protobuf:"bytes,24,opt,name=meta_network_name_full,json=metaNetworkNameFull,proto3" json:"meta_network_name_full,omitempty"`
	// Execution Context - Workflow (capabilities.RequestMetadata)
	MetaWorkflowId               string `protobuf:"bytes,25,opt,name=meta_workflow_id,json=metaWorkflowId,proto3" json:"meta_workflow_id,omitempty"`
	MetaWorkflowOwner            string `protobuf:"bytes,26,opt,name=meta_workflow_owner,json=metaWorkflowOwner,proto3" json:"meta_workflow_owner,omitempty"`
	MetaWorkflowExecutionId      string `` /* 135-byte string literal not displayed */
	MetaWorkflowName             string `protobuf:"bytes,28,opt,name=meta_workflow_name,json=metaWorkflowName,proto3" json:"meta_workflow_name,omitempty"`
	MetaWorkflowDonId            uint32 `protobuf:"varint,29,opt,name=meta_workflow_don_id,json=metaWorkflowDonId,proto3" json:"meta_workflow_don_id,omitempty"`
	MetaWorkflowDonConfigVersion uint32 `` /* 153-byte string literal not displayed */
	MetaReferenceId              string `protobuf:"bytes,31,opt,name=meta_reference_id,json=metaReferenceId,proto3" json:"meta_reference_id,omitempty"`
	// Execution Context - Capability
	MetaCapabilityType           string `protobuf:"bytes,32,opt,name=meta_capability_type,json=metaCapabilityType,proto3" json:"meta_capability_type,omitempty"`
	MetaCapabilityId             string `protobuf:"bytes,33,opt,name=meta_capability_id,json=metaCapabilityId,proto3" json:"meta_capability_id,omitempty"`
	MetaCapabilityTimestampStart uint64 `` /* 151-byte string literal not displayed */
	MetaCapabilityTimestampEmit  uint64 `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

WT skipped the write request

func (*WriteSkipped) Descriptor deprecated 

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

Deprecated: Use WriteSkipped.ProtoReflect.Descriptor instead.

func (*WriteSkipped) GetForwarder 

func (x *WriteSkipped) GetForwarder() string

func (*WriteSkipped) GetMetaCapabilityId 

func (x *WriteSkipped) GetMetaCapabilityId() string

func (*WriteSkipped) GetMetaCapabilityTimestampEmit 

func (x *WriteSkipped) GetMetaCapabilityTimestampEmit() uint64

func (*WriteSkipped) GetMetaCapabilityTimestampStart 

func (x *WriteSkipped) GetMetaCapabilityTimestampStart() uint64

func (*WriteSkipped) GetMetaCapabilityType 

func (x *WriteSkipped) GetMetaCapabilityType() string

func (*WriteSkipped) GetMetaChainFamilyName 

func (x *WriteSkipped) GetMetaChainFamilyName() string

func (*WriteSkipped) GetMetaChainId 

func (x *WriteSkipped) GetMetaChainId() string

func (*WriteSkipped) GetMetaNetworkName 

func (x *WriteSkipped) GetMetaNetworkName() string

func (*WriteSkipped) GetMetaNetworkNameFull 

func (x *WriteSkipped) GetMetaNetworkNameFull() string

func (*WriteSkipped) GetMetaReferenceId 

func (x *WriteSkipped) GetMetaReferenceId() string

func (*WriteSkipped) GetMetaSourceId 

func (x *WriteSkipped) GetMetaSourceId() string

func (*WriteSkipped) GetMetaWorkflowDonConfigVersion 

func (x *WriteSkipped) GetMetaWorkflowDonConfigVersion() uint32

func (*WriteSkipped) GetMetaWorkflowDonId 

func (x *WriteSkipped) GetMetaWorkflowDonId() uint32

func (*WriteSkipped) GetMetaWorkflowExecutionId 

func (x *WriteSkipped) GetMetaWorkflowExecutionId() string

func (*WriteSkipped) GetMetaWorkflowId 

func (x *WriteSkipped) GetMetaWorkflowId() string

func (*WriteSkipped) GetMetaWorkflowName 

func (x *WriteSkipped) GetMetaWorkflowName() string

func (*WriteSkipped) GetMetaWorkflowOwner 

func (x *WriteSkipped) GetMetaWorkflowOwner() string

func (*WriteSkipped) GetNode 

func (x *WriteSkipped) GetNode() string

func (*WriteSkipped) GetReason 

func (x *WriteSkipped) GetReason() string

func (*WriteSkipped) GetReceiver 

func (x *WriteSkipped) GetReceiver() string

func (*WriteSkipped) GetReportId 

func (x *WriteSkipped) GetReportId() uint32

func (*WriteSkipped) ProtoMessage 

func (*WriteSkipped) ProtoMessage()

func (*WriteSkipped) ProtoReflect 

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

func (*WriteSkipped) Reset 

func (x *WriteSkipped) Reset()

func (*WriteSkipped) String 

func (x *WriteSkipped) String() string

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.