event

package

v0.0.7 Latest Latest Go to latest Published: May 29, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

View Source

var ErrNotRunning = errors.New("not running")

func MarketplaceTxHandler(bus Bus) marketplace.Handler

func MarketplaceTxPublisher(ctx context.Context, log log.Logger, tmbus tmtmtypes.EventBusSubscriber, bus Bus) (marketplace.Monitor, error)

type Bus interface {
	Publish(Event) error
	Subscribe() (Subscriber, error)
	Close()
	Done() <-chan struct{}
}

func NewBus() Bus

type Event interface{}

type LeaseWon struct {
	LeaseID types.LeaseID
	Group   *types.DeploymentGroup
	Price   uint32
}

type ManifestReceived struct {
	LeaseID    types.LeaseID
	Manifest   *types.Manifest
	Deployment *types.Deployment
}

type Subscriber interface {
	Events() <-chan Event
	Clone() (Subscriber, error)
	Close()
	Done() <-chan struct{}
}

type TxCloseDeployment = types.TxCloseDeployment

type TxCloseFulfillment = types.TxCloseFulfillment

type TxCreateFulfillment = types.TxCreateFulfillment

type TxCreateLease = types.TxCreateLease

type TxCreateOrder = types.TxCreateOrder