oms

package

v0.1.0 Latest Latest Go to latest Published: Jul 22, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type OMS struct {
	actor.ActorBase
	// contains filtered or unexported fields
}

func NewOMS(c *cache.Cache) *OMS

func (o *OMS) Handle(ev msgbus.Event, bus *msgbus.MsgBus)

func (o *OMS) OnInit(config map[string]any)

func (o *OMS) OnOrderAccepted(ev event.OrderAccepted)

func (o *OMS) OnOrderCanceled(ev event.OrderCanceled)

func (o *OMS) OnOrderFilled(ev event.OrderFilled)

func (o *OMS) OnOrderNew(ev event.OrderNew)

func (o *OMS) OnOrderPartiallyFilled(ev event.OrderPartiallyFilled)

func (o *OMS) OnOrderRejected(ev event.OrderRejected)

func (o *OMS) OnOrderRiskInvalid(ev event.OrderRiskInvalid)

func (o *OMS) OnStart()

func (o *OMS) OnStop()

type OMSConfig struct {
	Subscription []string `yaml:"subscription"` // Event topic names to subscribe to
}

OMSConfig contains configuration for a single OMS actor instance.