chainevents

package

v0.1.2 Latest Latest Go to latest Published: May 22, 2019 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/scryinfo/dp

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL