chainevents

Documentation

Index

• Constants
• func ExecuteEvents(dataChannel chan events.Event, externalEventRepo *EventRepository)
• func ListenEvent(conn *ethclient.Client, contracts []ContractInfo, fromBlock uint64, ...) bool
• func SetFromBlock(from uint64)
• func StartEventProcessing(conn *ethclient.Client, contracts []ContractInfo)
• func SubscribeExternal(clientAddr common.Address, eventName string, eventCallback EventCallback) error
• func UnSubscribeExternal(clientAddr common.Address, eventName string) error
• type ContractInfo
• type EventCallback
• type EventRepository
  • func NewEventRepository() *EventRepository

Constants

const (
	BROADCAST_TO_USERS = "0x00"
	TARGET_USERS       = "users"
	TARGET_OWNER       = "owner"
	APP_SEQ_NO         = "seqNo"
	TOKEN_EVT_APPROVAL = "Approval"
)

Functions

func ExecuteEvents

func ExecuteEvents(dataChannel chan events.Event, externalEventRepo *EventRepository)

func ListenEvent

func ListenEvent(conn *ethclient.Client, contracts []ContractInfo, fromBlock uint64, interval time.Duration,
	dataChannel chan events.Event, errorChannel chan error) bool

func SetFromBlock

func SetFromBlock(from uint64)

func StartEventProcessing

func StartEventProcessing(
	conn *ethclient.Client,
	contracts []ContractInfo,
)

func SubscribeExternal

func SubscribeExternal(
	clientAddr common.Address,
	eventName string,
	eventCallback EventCallback,
) error

func UnSubscribeExternal

func UnSubscribeExternal(
	clientAddr common.Address,
	eventName string,
) error

Types

type ContractInfo

type ContractInfo struct {
	Address string
	Abi     string
	Events  []string
}

type EventCallback

type EventCallback func(event events.Event) bool

type EventRepository

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

func NewEventRepository

func NewEventRepository() *EventRepository