marketplace

Documentation

Index

• func TxQuery() pubsub.Query
• func TxQueryApp(name string) pubsub.Query
• func TxQueryCreateOrder() pubsub.Query
• func TxQueryTxType(name string) pubsub.Query
• type Builder
  • func NewBuilder() Builder
• type Handler
• type Monitor
  • func NewMonitor(ctx context.Context, log log.Logger, bus tmclient.EventsClient, name string, ...) (Monitor, error)

Functions

func TxQuery

func TxQuery() pubsub.Query

func TxQueryApp

func TxQueryApp(name string) pubsub.Query

func TxQueryCreateOrder

func TxQueryCreateOrder() pubsub.Query

func TxQueryTxType

func TxQueryTxType(name string) pubsub.Query

Types

type Builder

type Builder interface {
	OnTxSend(func(*types.TxSend)) Builder
	OnTxCreateProvider(func(*types.TxCreateProvider)) Builder
	OnTxCreateDeployment(func(*types.TxCreateDeployment)) Builder
	OnTxUpdateDeployment(func(*types.TxUpdateDeployment)) Builder
	OnTxCreateOrder(func(*types.TxCreateOrder)) Builder
	OnTxCreateFulfillment(func(*types.TxCreateFulfillment)) Builder
	OnTxCreateLease(func(*types.TxCreateLease)) Builder
	OnTxCloseDeployment(func(*types.TxCloseDeployment)) Builder
	OnTxCloseFulfillment(func(*types.TxCloseFulfillment)) Builder
	OnTxCloseLease(func(*types.TxCloseLease)) Builder
	Create() Handler
}

func NewBuilder

func NewBuilder() Builder

type Handler

type Handler interface {
	OnTxSend(*types.TxSend)
	OnTxCreateProvider(*types.TxCreateProvider)
	OnTxCreateDeployment(*types.TxCreateDeployment)
	OnTxUpdateDeployment(*types.TxUpdateDeployment)
	OnTxCreateOrder(*types.TxCreateOrder)
	OnTxCreateFulfillment(*types.TxCreateFulfillment)
	OnTxCreateLease(*types.TxCreateLease)
	OnTxCloseDeployment(*types.TxCloseDeployment)
	OnTxCloseFulfillment(*types.TxCloseFulfillment)
	OnTxCloseLease(*types.TxCloseLease)
}

type Monitor

type Monitor interface {
	Stop() error
	Wait() <-chan struct{}
}

func NewMonitor

func NewMonitor(ctx context.Context, log log.Logger, bus tmclient.EventsClient, name string, handler Handler, query pubsub.Query) (Monitor, error)