canceler

package

v0.0.0-...-45105f0 Latest Latest Go to latest Published: Nov 13, 2025 License: GPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Canceler struct {
	// contains filtered or unexported fields
}

func New(logger *slog.Logger, client bridge.AlpacaInterface, counters Counters, timeout time.Duration) *Canceler

func (c *Canceler) EventLoop(m jetstream.Msg)

type Counters struct {
	CancelCount, CancelFail       prometheus.Counter
	CancelAllCount, CancelAllFail prometheus.Counter
}