dealpusher

func (*DealPusher) Name ¶

func (*DealPusher) Name() string

func (*DealPusher) Start ¶

func (d *DealPusher) Start(ctx context.Context) ([]service.Done, service.Fail, error)

Start initializes and starts the DealPusher service.

It first attempts to register the worker with the health check system. If another worker is already running, it waits and retries until it can register or the context is cancelled. Once registered, it launches three main activities in separate goroutines:

1. Reporting its health status.
2. Running the deal processing loop.
3. Handling cleanup when the service is stopped.

Parameters:

• ctx : The context for managing the lifecycle of the Start function. If Done, the function exits cleanly.

Returns:

• A slice of channels that the caller can select on to wait for the service to stop.
• A channel for errors that may occur while the service is running.
• An error if there was a problem starting the service.

This function is intended to be called once at the start of the service lifecycle.