sessionworker

package

v1.64.2 Latest Latest Go to latest Published: Apr 14, 2026 License: AGPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DoFunc func(ctx context.Context, h *Handle)

type Handle struct {
	Key
	// contains filtered or unexported fields
}

func Get(session *bbgo.ExchangeSession, id string) *Handle

Get finds and returns the worker instance from the pool

func Start(ctx context.Context, session *bbgo.ExchangeSession, id string, w Worker) *Handle

Start starts a worker with the given exchange session, Please note the worker function will be executed immediately.

func (w *Handle) Session() *bbgo.ExchangeSession

func (w *Handle) SetValue(v any)

func (w *Handle) Start(ctx context.Context)

func (w *Handle) Value() any

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

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

func (p *Pool) Add(session *bbgo.ExchangeSession, id string, w Worker) *Handle

func (p *Pool) Get(session *bbgo.ExchangeSession, id string) *Handle

func (p *Pool) Start(ctx context.Context)

type Worker interface {
	Run(ctx context.Context, h *Handle)
}