market

Documentation

Index

• Constants
• func BestFulfillment(state state.State, order *types.Order) (*types.Fulfillment, error)
• func NewApp(logger log.Logger) (apptypes.Application, error)
• type Actor
  • func NewActor(key crypto.PrivKey) Actor
• type Client
• type Driver
  • func NewDriver(ctx context.Context, log log.Logger, actor Actor, bus *tmtmtypes.EventBus) (Driver, error)
  • func NewDriverWithFacilitator(ctx context.Context, log log.Logger, actor Actor, bus *tmtmtypes.EventBus, ...) (Driver, error)
• type Engine
  • func NewEngine(log log.Logger) Engine
• type Facilitator
  • func DefaultFacilitator(ctx context.Context, log log.Logger, actor Actor) Facilitator
  • func NewFacilitator(log log.Logger, actor Actor, engine Engine, client Client) Facilitator
  • func NewWorker(ctx context.Context, delegate Facilitator) Facilitator
• type Sender
  • func NewSender(log log.Logger, client Client, actor Actor, nonce uint64) Sender

Constants

const (
	Name = "marketplace"
)

Functions

func BestFulfillment

func BestFulfillment(state state.State, order *types.Order) (*types.Fulfillment, error)

func NewApp

func NewApp(logger log.Logger) (apptypes.Application, error)

Types

type Actor

type Actor interface {
	Sign([]byte) crypto.Signature
	PubKey() crypto.PubKey
	Address() []byte
}

func NewActor

func NewActor(key crypto.PrivKey) Actor

type Client

type Client interface {
	BroadcastTxAsync(tx tmtmtypes.Tx) (*ctypes.ResultBroadcastTx, error)
}

type Driver

type Driver interface {
	OnBeginBlock(req tmtypes.RequestBeginBlock) error
	OnCommit(state state.State) error
	Stop()
}

func NewDriver

func NewDriver(ctx context.Context, log log.Logger, actor Actor, bus *tmtmtypes.EventBus) (Driver, error)

func NewDriverWithFacilitator

func NewDriverWithFacilitator(ctx context.Context, log log.Logger, actor Actor, bus *tmtmtypes.EventBus, facilitator Facilitator) (Driver, error)

type Engine

type Engine interface {
	Run(state state.State) ([]interface{}, error)
}

func NewEngine

func NewEngine(log log.Logger) Engine

type Facilitator

type Facilitator interface {
	Run(state.State) error
}

func DefaultFacilitator

func DefaultFacilitator(ctx context.Context, log log.Logger, actor Actor) Facilitator

func NewFacilitator

func NewFacilitator(log log.Logger, actor Actor, engine Engine, client Client) Facilitator

func NewWorker

func NewWorker(ctx context.Context, delegate Facilitator) Facilitator

type Sender

type Sender interface {
	Send(payload interface{}) (uint64, error)
}

func NewSender

func NewSender(log log.Logger, client Client, actor Actor, nonce uint64) Sender