events

package
v0.0.0-...-62d6299 Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2025 License: MIT Imports: 5 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_workflows_v1_capability_finished_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_capability_started_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_metadata_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_metering_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_transmissions_scheduled_event_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_transmit_schedule_event_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_trigger_detail_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_user_logs_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_workflow_finished_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_workflow_started_proto protoreflect.FileDescriptor
View Source 
var File_workflows_v1_workflow_status_changed_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AggregatedSpendDetail 

type AggregatedSpendDetail struct {
	SpendUnit     string `protobuf:"bytes,2,opt,name=spend_unit,json=spendUnit,proto3" json:"spend_unit,omitempty"`
	SpendValue    string `protobuf:"bytes,3,opt,name=spend_value,json=spendValue,proto3" json:"spend_value,omitempty"`
	SpendValueCre string `protobuf:"bytes,4,opt,name=spend_value_cre,json=spendValueCre,proto3" json:"spend_value_cre,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedSpendDetail) Descriptor deprecated 

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

Deprecated: Use AggregatedSpendDetail.ProtoReflect.Descriptor instead.

func (*AggregatedSpendDetail) GetSpendUnit 

func (x *AggregatedSpendDetail) GetSpendUnit() string

func (*AggregatedSpendDetail) GetSpendValue 

func (x *AggregatedSpendDetail) GetSpendValue() string

func (*AggregatedSpendDetail) GetSpendValueCre 

func (x *AggregatedSpendDetail) GetSpendValueCre() string

func (*AggregatedSpendDetail) ProtoMessage 

func (*AggregatedSpendDetail) ProtoMessage()

func (*AggregatedSpendDetail) ProtoReflect 

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

func (*AggregatedSpendDetail) Reset 

func (x *AggregatedSpendDetail) Reset()

func (*AggregatedSpendDetail) String 

func (x *AggregatedSpendDetail) String() string

type CapabilityExecutionFinished 

type CapabilityExecutionFinished struct {
	M            *WorkflowMetadata `protobuf:"bytes,1,opt,name=m,proto3" json:"m,omitempty"`
	Timestamp    string            `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CapabilityID string            `protobuf:"bytes,3,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	StepRef      string            `protobuf:"bytes,4,opt,name=stepRef,proto3" json:"stepRef,omitempty"`
	Status       string            `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CapabilityExecutionFinished) Descriptor deprecated 

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

Deprecated: Use CapabilityExecutionFinished.ProtoReflect.Descriptor instead.

func (*CapabilityExecutionFinished) GetCapabilityID 

func (x *CapabilityExecutionFinished) GetCapabilityID() string

func (*CapabilityExecutionFinished) GetM 

func (x *CapabilityExecutionFinished) GetM() *WorkflowMetadata

func (*CapabilityExecutionFinished) GetStatus 

func (x *CapabilityExecutionFinished) GetStatus() string

func (*CapabilityExecutionFinished) GetStepRef 

func (x *CapabilityExecutionFinished) GetStepRef() string

func (*CapabilityExecutionFinished) GetTimestamp 

func (x *CapabilityExecutionFinished) GetTimestamp() string

func (*CapabilityExecutionFinished) ProtoMessage 

func (*CapabilityExecutionFinished) ProtoMessage()

func (*CapabilityExecutionFinished) ProtoReflect 

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

func (*CapabilityExecutionFinished) Reset 

func (x *CapabilityExecutionFinished) Reset()

func (*CapabilityExecutionFinished) String 

func (x *CapabilityExecutionFinished) String() string

type CapabilityExecutionStarted 

type CapabilityExecutionStarted struct {
	M            *WorkflowMetadata `protobuf:"bytes,1,opt,name=m,proto3" json:"m,omitempty"`
	Timestamp    string            `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CapabilityID string            `protobuf:"bytes,3,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	StepRef      string            `protobuf:"bytes,4,opt,name=stepRef,proto3" json:"stepRef,omitempty"`
	// contains filtered or unexported fields
}

func (*CapabilityExecutionStarted) Descriptor deprecated 

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

Deprecated: Use CapabilityExecutionStarted.ProtoReflect.Descriptor instead.

func (*CapabilityExecutionStarted) GetCapabilityID 

func (x *CapabilityExecutionStarted) GetCapabilityID() string

func (*CapabilityExecutionStarted) GetM 

func (x *CapabilityExecutionStarted) GetM() *WorkflowMetadata

func (*CapabilityExecutionStarted) GetStepRef 

func (x *CapabilityExecutionStarted) GetStepRef() string

func (*CapabilityExecutionStarted) GetTimestamp 

func (x *CapabilityExecutionStarted) GetTimestamp() string

func (*CapabilityExecutionStarted) ProtoMessage 

func (*CapabilityExecutionStarted) ProtoMessage()

func (*CapabilityExecutionStarted) ProtoReflect 

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

func (*CapabilityExecutionStarted) Reset 

func (x *CapabilityExecutionStarted) Reset()

func (*CapabilityExecutionStarted) String 

func (x *CapabilityExecutionStarted) String() string

type LogLine 

type LogLine struct {
	NodeTimestamp string `protobuf:"bytes,1,opt,name=node_timestamp,json=nodeTimestamp,proto3" json:"node_timestamp,omitempty"`
	Message       string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLine) Descriptor deprecated 

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

Deprecated: Use LogLine.ProtoReflect.Descriptor instead.

func (*LogLine) GetMessage 

func (x *LogLine) GetMessage() string

func (*LogLine) GetNodeTimestamp 

func (x *LogLine) GetNodeTimestamp() string

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) ProtoReflect 

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

func (*LogLine) Reset 

func (x *LogLine) Reset()

func (*LogLine) String 

func (x *LogLine) String() string

type MeteringReport 

type MeteringReport struct {
	Steps        map[string]*MeteringReportStep `` /* 137-byte string literal not displayed */
	Metadata     *WorkflowMetadata              `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	MeteringMode bool                           `protobuf:"varint,3,opt,name=meteringMode,proto3" json:"meteringMode,omitempty"`
	Message      string                         `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

MeteringReport is consumed by the engine in core to emit the final Metering Report.

func (*MeteringReport) Descriptor deprecated 

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

Deprecated: Use MeteringReport.ProtoReflect.Descriptor instead.

func (*MeteringReport) GetMessage 

func (x *MeteringReport) GetMessage() string

func (*MeteringReport) GetMetadata 

func (x *MeteringReport) GetMetadata() *WorkflowMetadata

func (*MeteringReport) GetMeteringMode 

func (x *MeteringReport) GetMeteringMode() bool

func (*MeteringReport) GetSteps 

func (x *MeteringReport) GetSteps() map[string]*MeteringReportStep

func (*MeteringReport) ProtoMessage 

func (*MeteringReport) ProtoMessage()

func (*MeteringReport) ProtoReflect 

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

func (*MeteringReport) Reset 

func (x *MeteringReport) Reset()

func (*MeteringReport) String 

func (x *MeteringReport) String() string

type MeteringReportNodeDetail 

type MeteringReportNodeDetail struct {
	Peer_2PeerId  string `protobuf:"bytes,1,opt,name=peer_2_peer_id,json=peer2PeerId,proto3" json:"peer_2_peer_id,omitempty"`
	SpendUnit     string `protobuf:"bytes,2,opt,name=spend_unit,json=spendUnit,proto3" json:"spend_unit,omitempty"`
	SpendValue    string `protobuf:"bytes,3,opt,name=spend_value,json=spendValue,proto3" json:"spend_value,omitempty"`
	SpendValueCre string `protobuf:"bytes,4,opt,name=spend_value_cre,json=spendValueCre,proto3" json:"spend_value_cre,omitempty"`
	// contains filtered or unexported fields
}

func (*MeteringReportNodeDetail) Descriptor deprecated 

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

Deprecated: Use MeteringReportNodeDetail.ProtoReflect.Descriptor instead.

func (*MeteringReportNodeDetail) GetPeer_2PeerId 

func (x *MeteringReportNodeDetail) GetPeer_2PeerId() string

func (*MeteringReportNodeDetail) GetSpendUnit 

func (x *MeteringReportNodeDetail) GetSpendUnit() string

func (*MeteringReportNodeDetail) GetSpendValue 

func (x *MeteringReportNodeDetail) GetSpendValue() string

func (*MeteringReportNodeDetail) GetSpendValueCre 

func (x *MeteringReportNodeDetail) GetSpendValueCre() string

func (*MeteringReportNodeDetail) ProtoMessage 

func (*MeteringReportNodeDetail) ProtoMessage()

func (*MeteringReportNodeDetail) ProtoReflect 

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

func (*MeteringReportNodeDetail) Reset 

func (x *MeteringReportNodeDetail) Reset()

func (*MeteringReportNodeDetail) String 

func (x *MeteringReportNodeDetail) String() string

type MeteringReportStep 

type MeteringReportStep struct {
	Nodes            []*MeteringReportNodeDetail `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	AggSpendValue    string                      `protobuf:"bytes,2,opt,name=agg_spend_value,json=aggSpendValue,proto3" json:"agg_spend_value,omitempty"`            // remove after ensuring no longer used
	AggSpendUnit     string                      `protobuf:"bytes,3,opt,name=agg_spend_unit,json=aggSpendUnit,proto3" json:"agg_spend_unit,omitempty"`               // remove after ensuring no longer used
	AggSpendValueCre string                      `protobuf:"bytes,4,opt,name=agg_spend_value_cre,json=aggSpendValueCre,proto3" json:"agg_spend_value_cre,omitempty"` // remove after ensuring no longer used
	CapdonN          uint32                      `protobuf:"varint,5,opt,name=capdon_n,json=capdonN,proto3" json:"capdon_n,omitempty"`                               // capdon_n provides the total node count for capability DONs
	AggSpend         []*AggregatedSpendDetail    `protobuf:"bytes,6,rep,name=agg_spend,json=aggSpend,proto3" json:"agg_spend,omitempty"`
	// contains filtered or unexported fields
}

func (*MeteringReportStep) Descriptor deprecated 

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

Deprecated: Use MeteringReportStep.ProtoReflect.Descriptor instead.

func (*MeteringReportStep) GetAggSpend 

func (x *MeteringReportStep) GetAggSpend() []*AggregatedSpendDetail

func (*MeteringReportStep) GetAggSpendUnit 

func (x *MeteringReportStep) GetAggSpendUnit() string

func (*MeteringReportStep) GetAggSpendValue 

func (x *MeteringReportStep) GetAggSpendValue() string

func (*MeteringReportStep) GetAggSpendValueCre 

func (x *MeteringReportStep) GetAggSpendValueCre() string

func (*MeteringReportStep) GetCapdonN 

func (x *MeteringReportStep) GetCapdonN() uint32

func (*MeteringReportStep) GetNodes 

func (x *MeteringReportStep) GetNodes() []*MeteringReportNodeDetail

func (*MeteringReportStep) ProtoMessage 

func (*MeteringReportStep) ProtoMessage()

func (*MeteringReportStep) ProtoReflect 

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

func (*MeteringReportStep) Reset 

func (x *MeteringReportStep) Reset()

func (*MeteringReportStep) String 

func (x *MeteringReportStep) String() string

type TransactionInfo 

type TransactionInfo struct {
	ChainSelector string `protobuf:"bytes,1,opt,name=chainSelector,proto3" json:"chainSelector,omitempty"`
	TxHash        string `protobuf:"bytes,2,opt,name=txHash,proto3" json:"txHash,omitempty"`
	GasCost       string `protobuf:"bytes,3,opt,name=gasCost,proto3" json:"gasCost,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionInfo) Descriptor deprecated 

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

Deprecated: Use TransactionInfo.ProtoReflect.Descriptor instead.

func (*TransactionInfo) GetChainSelector 

func (x *TransactionInfo) GetChainSelector() string

func (*TransactionInfo) GetGasCost 

func (x *TransactionInfo) GetGasCost() string

func (*TransactionInfo) GetTxHash 

func (x *TransactionInfo) GetTxHash() string

func (*TransactionInfo) ProtoMessage 

func (*TransactionInfo) ProtoMessage()

func (*TransactionInfo) ProtoReflect 

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

func (*TransactionInfo) Reset 

func (x *TransactionInfo) Reset()

func (*TransactionInfo) String 

func (x *TransactionInfo) String() string

type TransmissionsScheduledEvent 

type TransmissionsScheduledEvent struct {
	Timestamp           string `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ScheduleType        string `protobuf:"bytes,2,opt,name=scheduleType,proto3" json:"scheduleType,omitempty"`
	WorkflowExecutionID string `protobuf:"bytes,3,opt,name=workflowExecutionID,proto3" json:"workflowExecutionID,omitempty"`
	TransmissionID      string `protobuf:"bytes,4,opt,name=transmissionID,proto3" json:"transmissionID,omitempty"`
	CapabilityID        string `protobuf:"bytes,5,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	StepRef             string `protobuf:"bytes,6,opt,name=stepRef,proto3" json:"stepRef,omitempty"`
	// Map of peerID to transmission delay in milliseconds
	PeerTransmissionDelays map[string]int64 `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TransmissionsScheduledEvent) Descriptor deprecated 

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

Deprecated: Use TransmissionsScheduledEvent.ProtoReflect.Descriptor instead.

func (*TransmissionsScheduledEvent) GetCapabilityID 

func (x *TransmissionsScheduledEvent) GetCapabilityID() string

func (*TransmissionsScheduledEvent) GetPeerTransmissionDelays 

func (x *TransmissionsScheduledEvent) GetPeerTransmissionDelays() map[string]int64

func (*TransmissionsScheduledEvent) GetScheduleType 

func (x *TransmissionsScheduledEvent) GetScheduleType() string

func (*TransmissionsScheduledEvent) GetStepRef 

func (x *TransmissionsScheduledEvent) GetStepRef() string

func (*TransmissionsScheduledEvent) GetTimestamp 

func (x *TransmissionsScheduledEvent) GetTimestamp() string

func (*TransmissionsScheduledEvent) GetTransmissionID 

func (x *TransmissionsScheduledEvent) GetTransmissionID() string

func (*TransmissionsScheduledEvent) GetWorkflowExecutionID 

func (x *TransmissionsScheduledEvent) GetWorkflowExecutionID() string

func (*TransmissionsScheduledEvent) ProtoMessage 

func (*TransmissionsScheduledEvent) ProtoMessage()

func (*TransmissionsScheduledEvent) ProtoReflect 

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

func (*TransmissionsScheduledEvent) Reset 

func (x *TransmissionsScheduledEvent) Reset()

func (*TransmissionsScheduledEvent) String 

func (x *TransmissionsScheduledEvent) String() string

type TransmitScheduleEvent 

type TransmitScheduleEvent struct {
	Timestamp           string `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ScheduleType        string `protobuf:"bytes,2,opt,name=scheduleType,proto3" json:"scheduleType,omitempty"`
	WorkflowExecutionID string `protobuf:"bytes,3,opt,name=workflowExecutionID,proto3" json:"workflowExecutionID,omitempty"`
	TransmissionID      string `protobuf:"bytes,4,opt,name=transmissionID,proto3" json:"transmissionID,omitempty"`
	CapabilityID        string `protobuf:"bytes,5,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	StepRef             string `protobuf:"bytes,6,opt,name=stepRef,proto3" json:"stepRef,omitempty"`
	// Map of peerID to transmission delay in milliseconds
	PeerTransmissionDelays map[string]int64 `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

Old name for backwards compatibility Copy of TransmissionsScheduledEvent

func (*TransmitScheduleEvent) Descriptor deprecated 

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

Deprecated: Use TransmitScheduleEvent.ProtoReflect.Descriptor instead.

func (*TransmitScheduleEvent) GetCapabilityID 

func (x *TransmitScheduleEvent) GetCapabilityID() string

func (*TransmitScheduleEvent) GetPeerTransmissionDelays 

func (x *TransmitScheduleEvent) GetPeerTransmissionDelays() map[string]int64

func (*TransmitScheduleEvent) GetScheduleType 

func (x *TransmitScheduleEvent) GetScheduleType() string

func (*TransmitScheduleEvent) GetStepRef 

func (x *TransmitScheduleEvent) GetStepRef() string

func (*TransmitScheduleEvent) GetTimestamp 

func (x *TransmitScheduleEvent) GetTimestamp() string

func (*TransmitScheduleEvent) GetTransmissionID 

func (x *TransmitScheduleEvent) GetTransmissionID() string

func (*TransmitScheduleEvent) GetWorkflowExecutionID 

func (x *TransmitScheduleEvent) GetWorkflowExecutionID() string

func (*TransmitScheduleEvent) ProtoMessage 

func (*TransmitScheduleEvent) ProtoMessage()

func (*TransmitScheduleEvent) ProtoReflect 

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

func (*TransmitScheduleEvent) Reset 

func (x *TransmitScheduleEvent) Reset()

func (*TransmitScheduleEvent) String 

func (x *TransmitScheduleEvent) String() string

type TriggerDetail 

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

This message was carved out from metadata.proto file because of backward compatibility (FULL_TRANSITIVE) requirements of Confluent Schema Registry.

func (*TriggerDetail) Descriptor deprecated 

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

Deprecated: Use TriggerDetail.ProtoReflect.Descriptor instead.

func (*TriggerDetail) GetTriggerID 

func (x *TriggerDetail) GetTriggerID() string

func (*TriggerDetail) ProtoMessage 

func (*TriggerDetail) ProtoMessage()

func (*TriggerDetail) ProtoReflect 

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

func (*TriggerDetail) Reset 

func (x *TriggerDetail) Reset()

func (*TriggerDetail) String 

func (x *TriggerDetail) String() string

type UserLogs 

type UserLogs struct {
	M        *WorkflowMetadata `protobuf:"bytes,1,opt,name=m,proto3" json:"m,omitempty"`
	LogLines []*LogLine        `protobuf:"bytes,2,rep,name=log_lines,json=logLines,proto3" json:"log_lines,omitempty"`
	// contains filtered or unexported fields
}

func (*UserLogs) Descriptor deprecated 

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

Deprecated: Use UserLogs.ProtoReflect.Descriptor instead.

func (*UserLogs) GetLogLines 

func (x *UserLogs) GetLogLines() []*LogLine

func (*UserLogs) GetM 

func (x *UserLogs) GetM() *WorkflowMetadata

func (*UserLogs) ProtoMessage 

func (*UserLogs) ProtoMessage()

func (*UserLogs) ProtoReflect 

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

func (*UserLogs) Reset 

func (x *UserLogs) Reset()

func (*UserLogs) String 

func (x *UserLogs) String() string

type WorkflowExecutionFinished 

type WorkflowExecutionFinished struct {
	M         *WorkflowMetadata `protobuf:"bytes,1,opt,name=m,proto3" json:"m,omitempty"`
	Timestamp string            `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Status    string            `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowExecutionFinished) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionFinished.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionFinished) GetM 

func (x *WorkflowExecutionFinished) GetM() *WorkflowMetadata

func (*WorkflowExecutionFinished) GetStatus 

func (x *WorkflowExecutionFinished) GetStatus() string

func (*WorkflowExecutionFinished) GetTimestamp 

func (x *WorkflowExecutionFinished) GetTimestamp() string

func (*WorkflowExecutionFinished) ProtoMessage 

func (*WorkflowExecutionFinished) ProtoMessage()

func (*WorkflowExecutionFinished) ProtoReflect 

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

func (*WorkflowExecutionFinished) Reset 

func (x *WorkflowExecutionFinished) Reset()

func (*WorkflowExecutionFinished) String 

func (x *WorkflowExecutionFinished) String() string

type WorkflowExecutionStarted 

type WorkflowExecutionStarted struct {
	M         *WorkflowMetadata `protobuf:"bytes,1,opt,name=m,proto3" json:"m,omitempty"`
	Timestamp string            `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TriggerID string            `protobuf:"bytes,3,opt,name=TriggerID,proto3" json:"TriggerID,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowExecutionStarted) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionStarted.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionStarted) GetM 

func (x *WorkflowExecutionStarted) GetM() *WorkflowMetadata

func (*WorkflowExecutionStarted) GetTimestamp 

func (x *WorkflowExecutionStarted) GetTimestamp() string

func (*WorkflowExecutionStarted) GetTriggerID 

func (x *WorkflowExecutionStarted) GetTriggerID() string

func (*WorkflowExecutionStarted) ProtoMessage 

func (*WorkflowExecutionStarted) ProtoMessage()

func (*WorkflowExecutionStarted) ProtoReflect 

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

func (*WorkflowExecutionStarted) Reset 

func (x *WorkflowExecutionStarted) Reset()

func (*WorkflowExecutionStarted) String 

func (x *WorkflowExecutionStarted) String() string

type WorkflowMetadata 

type WorkflowMetadata struct {
	WorkflowOwner           string         `protobuf:"bytes,1,opt,name=workflowOwner,proto3" json:"workflowOwner,omitempty"`
	WorkflowName            string         `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	Version                 string         `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	WorkflowID              string         `protobuf:"bytes,4,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	WorkflowExecutionID     string         `protobuf:"bytes,5,opt,name=workflowExecutionID,proto3" json:"workflowExecutionID,omitempty"`
	DonID                   int32          `protobuf:"varint,6,opt,name=donID,proto3" json:"donID,omitempty"`
	DonF                    int32          `protobuf:"varint,7,opt,name=donF,proto3" json:"donF,omitempty"`
	DonN                    int32          `protobuf:"varint,8,opt,name=donN,proto3" json:"donN,omitempty"`
	P2PID                   string         `protobuf:"bytes,9,opt,name=p2pID,proto3" json:"p2pID,omitempty"`
	WorkflowRegistryAddress string         `protobuf:"bytes,10,opt,name=workflowRegistryAddress,proto3" json:"workflowRegistryAddress,omitempty"`
	WorkflowRegistryVersion string         `protobuf:"bytes,11,opt,name=workflowRegistryVersion,proto3" json:"workflowRegistryVersion,omitempty"`
	WorkflowRegistryChain   string         `protobuf:"bytes,12,opt,name=workflowRegistryChain,proto3" json:"workflowRegistryChain,omitempty"`
	EngineVersion           string         `protobuf:"bytes,13,opt,name=engineVersion,proto3" json:"engineVersion,omitempty"`
	DonVersion              string         `protobuf:"bytes,14,opt,name=donVersion,proto3" json:"donVersion,omitempty"`
	Trigger                 *TriggerDetail `protobuf:"bytes,15,opt,name=trigger,proto3" json:"trigger,omitempty"`
	OrgID                   string         `protobuf:"bytes,16,opt,name=orgID,proto3" json:"orgID,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowMetadata) Descriptor deprecated 

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

Deprecated: Use WorkflowMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowMetadata) GetDonF 

func (x *WorkflowMetadata) GetDonF() int32

func (*WorkflowMetadata) GetDonID 

func (x *WorkflowMetadata) GetDonID() int32

func (*WorkflowMetadata) GetDonN 

func (x *WorkflowMetadata) GetDonN() int32

func (*WorkflowMetadata) GetDonVersion 

func (x *WorkflowMetadata) GetDonVersion() string

func (*WorkflowMetadata) GetEngineVersion 

func (x *WorkflowMetadata) GetEngineVersion() string

func (*WorkflowMetadata) GetOrgID 

func (x *WorkflowMetadata) GetOrgID() string

func (*WorkflowMetadata) GetP2PID 

func (x *WorkflowMetadata) GetP2PID() string

func (*WorkflowMetadata) GetTrigger 

func (x *WorkflowMetadata) GetTrigger() *TriggerDetail

func (*WorkflowMetadata) GetVersion 

func (x *WorkflowMetadata) GetVersion() string

func (*WorkflowMetadata) GetWorkflowExecutionID 

func (x *WorkflowMetadata) GetWorkflowExecutionID() string

func (*WorkflowMetadata) GetWorkflowID 

func (x *WorkflowMetadata) GetWorkflowID() string

func (*WorkflowMetadata) GetWorkflowName 

func (x *WorkflowMetadata) GetWorkflowName() string

func (*WorkflowMetadata) GetWorkflowOwner 

func (x *WorkflowMetadata) GetWorkflowOwner() string

func (*WorkflowMetadata) GetWorkflowRegistryAddress 

func (x *WorkflowMetadata) GetWorkflowRegistryAddress() string

func (*WorkflowMetadata) GetWorkflowRegistryChain 

func (x *WorkflowMetadata) GetWorkflowRegistryChain() string

func (*WorkflowMetadata) GetWorkflowRegistryVersion 

func (x *WorkflowMetadata) GetWorkflowRegistryVersion() string

func (*WorkflowMetadata) ProtoMessage 

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) ProtoReflect 

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

func (*WorkflowMetadata) Reset 

func (x *WorkflowMetadata) Reset()

func (*WorkflowMetadata) String 

func (x *WorkflowMetadata) String() string

type WorkflowStatusChanged 

type WorkflowStatusChanged struct {
	M       *WorkflowMetadata `protobuf:"bytes,1,opt,name=m,proto3" json:"m,omitempty"`
	Status  string            `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Details string            `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	TxInfo  *TransactionInfo  `protobuf:"bytes,4,opt,name=txInfo,proto3" json:"txInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowStatusChanged) Descriptor deprecated 

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

Deprecated: Use WorkflowStatusChanged.ProtoReflect.Descriptor instead.

func (*WorkflowStatusChanged) GetDetails 

func (x *WorkflowStatusChanged) GetDetails() string

func (*WorkflowStatusChanged) GetM 

func (x *WorkflowStatusChanged) GetM() *WorkflowMetadata

func (*WorkflowStatusChanged) GetStatus 

func (x *WorkflowStatusChanged) GetStatus() string

func (*WorkflowStatusChanged) GetTxInfo 

func (x *WorkflowStatusChanged) GetTxInfo() *TransactionInfo

func (*WorkflowStatusChanged) ProtoMessage 

func (*WorkflowStatusChanged) ProtoMessage()

func (*WorkflowStatusChanged) ProtoReflect 

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

func (*WorkflowStatusChanged) Reset 

func (x *WorkflowStatusChanged) Reset()

func (*WorkflowStatusChanged) String 

func (x *WorkflowStatusChanged) 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.