Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

workflows

package module

Go to main page

Versions in this module

v0

v0.0.17

Mar 25, 2026

v0.0.16

Mar 19, 2026

Changes in this version

+ func ConfidenceLevelFromString(s string) evm.ConfidenceLevel

type Config

+ ConfidenceLevel string

+ type RetryConfig struct

+ InitialDelay string

+ MaxAttempts int

v0.0.15

Mar 4, 2026

Changes in this version

+ var Attempts = 3

+ var CurrencyCodes = map[uint8]string

+ var ErrNilVerifiableEvent = errors.New("verifiable event cannot be nil")

+ var InitialRetryDelay = 5 * time.Second

+ func BuildEVMEventFromLog(rt cre.Runtime, cfg *Config, payload *evm.Log) (*models.EVMEvent, error)

+ func BuildVerifiableEventForEVMEvent(cfg *Config, ev *models.EVMEvent, service *string, name string, ...) (*models.VerifiableEvent, error)

+ func CheckResponse(resp *httpcap.Response) (*httpcap.Response, error)

+ func ComputeEventHash(encoded string) (common.Hash, error)

+ func CursorFromPB(blockNumber *pb.BigInt, logIndex uint64, txHash string) string

+ func DecodeEventParams(abiJSON, eventName string, log *evm.Log) (map[string]any, error)

+ func DecodeVerifiableEvent(encoded string) (*models.VerifiableEvent, error)

+ func EncodeVerifiableEvent(ve *models.VerifiableEvent) (string, error)

+ func EnsureChainSelector(cfg *Config, fallback string) string

+ func GetBlockTimestamp(rt cre.Runtime, chainSelector string, blockNumber *pb.BigInt) uint64

+ func GetContractABI(cfg *Config, contractName string) (string, error)

+ func GetCurrencyCode(currencyId uint8) string

+ func GetEventNameFromLog(cfg *Config, payload *evm.Log, abiJSON string) (string, error)

+ func GetEventSignature(cfg *Config, eventName string) string

+ func InitEventListenerWorkflow(cfg *Config, handler LogHandler) (cre.Workflow[*Config], error)

+ func MustEvent(abiJSON, eventName string) gethAbi.Event

+ func NewEVMLogFilter(contractAddr string, eventSigHashes [][]byte) *evm.FilterLogTriggerRequest

+ func PBToUint64(b *pb.BigInt) uint64

+ func ParseChainSelector(chainSelectorStr *string) (*uint64, error)

+ func PrepareTestingRuntime(t *testing.T) *testutils.TestRuntime

+ func Retry[T any](logger *slog.Logger, name string, fn func() (T, error)) (T, error)

+ func SanitiseJSON(v any) any

+ func SignAndPostVerifiableEvent(cfg *Config, rt cre.Runtime, ve *models.VerifiableEvent) (string, error)

+ func StopRetry(err error) error

+ func TxHashFromLog(l *evm.Log) string

+ type Config struct

+ ApiKeySecret string

+ ChainID string

+ ChainSelector string

+ CourierURL string

+ DetectEventTriggerConfig DetectEventTriggerConfig

+ Network string

+ Service *string

+ WatcherID string

+ WorkflowName string

+ func ParseWorkflowConfig(b []byte) (*Config, error)

+ type ContractDef struct

+ ContractABI any

+ type ContractReaderConfig struct

+ Contracts map[string]ContractDef

+ type DetectEventTriggerConfig struct

+ ContractAddress string

+ ContractEventNames []string

+ ContractName string

+ ContractReaderConfig ContractReaderConfig

+ type Fixed2 float64

+ func (f *Fixed2) UnmarshalJSON(data []byte) error

+ func (f Fixed2) MarshalJSON() ([]byte, error)

+ type LogHandler func(*Config, cre.Runtime, *evm.Log) (string, error)

+ type OffChainReferenceData struct

+ Data map[string]any

+ Source OffChainReferenceDataSource

+ func GetCurrencyCodeAsOffChainReferenceData(currencyId uint8) OffChainReferenceData

+ type OffChainReferenceDataSource struct

+ Identifier string

+ Type string

+ type OnChainReferenceData struct

+ Data map[string]any

+ Source OnChainReferenceDataSource

+ type OnChainReferenceDataSource struct

+ Block string

+ CallData string

+ ContractAddress string

+ ContractFunctionSignature string

+ type PaymentCallback struct

+ ContractAddress string

+ FunctionName string

+ FunctionSignature string

+ type PaymentRequest struct

+ Amount Fixed2

+ ApplicationAddr string

+ ApplicationType string

+ ChainID string

+ Currency string

+ CustomCallback *PaymentCallback

+ E2EID string

+ Expiration *int64

+ Receiver string

+ Sender string

+ type RawMessageType string

+ const RawMessageTypeMap

+ const RawMessageTypePaymentRequest

+ const RawMessageTypeReferenceData

+ type ReferenceData struct

+ OffChain []OffChainReferenceData

+ OnChain []OnChainReferenceData

+ Requests []TypeAndValue

+ func GetReferenceDataFromVerifiableEvent(verifiableEvent models.VerifiableEvent) (*ReferenceData, error)

+ type TypeAndValue struct

+ Type RawMessageType

+ Value json.RawMessage