clients

type Client interface {
	// ListenToTicks listens to ticks from the given exchange and pair.
	ListenToTicks(
		ctx context.Context,
		listener ListenerParams,
		exchange, pair string,
	) error
	// StopListeningToTicks unregisters a callback workflow from ticks for a given exchange and pair.
	StopListeningToTicks(
		ctx context.Context,
		listener uuid.UUID,
		exchange string,
		pair string,
	) error
	// Info calls the service info.
	Info(ctx context.Context) (api.ServiceInfoResults, error)
	// TemporalClient returns the underlying temporal client.
	TemporalClient() temporalclient.Client
}

type ClientOptions struct {
	UserAgent string
}

type ListenerParams struct {
	RequesterID uuid.UUID

	CallbackNamePrefix string
	Callback           func(ctx workflow.Context, params api.ListenToTicksCallbackWorkflowParams) error

	Worker    worker.Worker
	TaskQueue string
}

type WfClient interface {
	// ListenToTicks listens to ticks from the given exchange and pair.
	ListenToTicks(
		ctx workflow.Context,
		params api.RegisterForTicksListeningWorkflowParams,
	) (api.RegisterForTicksListeningWorkflowResults, error)

	// StopListeningToTicks unregisters a callback workflow from ticks for a given exchange and pair.
	StopListeningToTicks(
		ctx workflow.Context,
		params api.UnregisterFromTicksListeningWorkflowParams,
	) (api.UnregisterFromTicksListeningWorkflowResults, error)
}