Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrNotImplemented is returned when the function is not implemented. ErrNotImplemented = errors.New("not implemented") )
Functions ¶
This section is empty.
Types ¶
type SubscribeToPriceParams ¶ added in v1.6.0
SubscribeToPriceParams is the parameters to subscribe to price updates.
type WfClient ¶
type WfClient interface {
// SubscribeToPrice subscribes to specific price updates.
SubscribeToPrice(
ctx workflow.Context,
params SubscribeToPriceParams,
) error
// ListCandlesticks lists candlesticks from Cryptellation service.
ListCandlesticks(
ctx workflow.Context,
params candlesticksapi.ListCandlesticksWorkflowParams,
childWorkflowOptions *workflow.ChildWorkflowOptions,
) (result candlesticksapi.ListCandlesticksWorkflowResults, err error)
// GetExchange calls the exchange get workflow.
GetExchange(
ctx workflow.Context,
params exchangesapi.GetExchangeWorkflowParams,
childWorkflowOptions *workflow.ChildWorkflowOptions,
) (result exchangesapi.GetExchangeWorkflowResults, err error)
}
WfClient is a client for the cryptellation exchanges service from a workflow perspective.
func NewWfClient ¶
func NewWfClient() WfClient
NewWfClient creates a new workflow client. This client is used to call workflows from within other workflows. It is not used to call workflows from outside the workflow environment.
Click to show internal directories.
Click to hide internal directories.