Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PipelineCancelSignalBus ¶
type PipelineCancelSignalBus struct {
// contains filtered or unexported fields
}
func NewPipelineCancelSignalBus ¶
func NewPipelineCancelSignalBus(conn *nats.Conn) PipelineCancelSignalBus
func (PipelineCancelSignalBus) PublishPipelineCancel ¶
func (p PipelineCancelSignalBus) PublishPipelineCancel(pipeID string) error
func (PipelineCancelSignalBus) SubscribePipelineCancel ¶
func (p PipelineCancelSignalBus) SubscribePipelineCancel(pipeID string) (<-chan service.CancelSignal, error)
Source Files
Click to show internal directories.
Click to hide internal directories.