api

Documentation

Index

• type Broker
• type Server
  • func NewServer(store store.Store, broker Broker, workflows WorkflowService, cfg config.Config) *Server
  • func (s *Server) Router() http.Handler
  • func (s *Server) Start(ctx context.Context, addr string) error
• type WorkflowService

Types

type Broker

type Broker interface {
	Publish(event events.RunEvent)
	Subscribe(ctx context.Context, runID string) <-chan events.RunEvent
}

type Server

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

func NewServer

func NewServer(store store.Store, broker Broker, workflows WorkflowService, cfg config.Config) *Server

func (*Server) Router

func (s *Server) Router() http.Handler

func (*Server) Start

func (s *Server) Start(ctx context.Context, addr string) error

type WorkflowService

type WorkflowService interface {
	StartRun(ctx context.Context, runID string) error
	SignalMessage(ctx context.Context, runID string, message string) error
	ResumeRun(ctx context.Context, runID string, message string) error
	CancelRun(ctx context.Context, runID string) error
}