server

Documentation

Index

• Variables
• type CerealService
  • func NewCerealService(ctx context.Context, b libcereal.Driver) *CerealService
  • func (s *CerealService) CancelWorkflow(ctx context.Context, req *cereal.CancelWorkflowRequest) (*cereal.CancelWorkflowResponse, error)
  • func (s *CerealService) CreateWorkflowSchedule(ctx context.Context, req *cereal.CreateWorkflowScheduleRequest) (*cereal.CreateWorkflowScheduleResponse, error)
  • func (s *CerealService) DequeueTask(req cereal.CerealService_DequeueTaskServer) error
  • func (s *CerealService) DequeueWorkflow(req cereal.CerealService_DequeueWorkflowServer) error
  • func (s *CerealService) DequeueWorkflowChunk(req cereal.CerealService_DequeueWorkflowChunkServer) error
  • func (s *CerealService) EnqueueWorkflow(ctx context.Context, req *cereal.EnqueueWorkflowRequest) (*cereal.EnqueueWorkflowResponse, error)
  • func (s *CerealService) GetWorkflowInstanceByName(ctx context.Context, req *cereal.GetWorkflowInstanceByNameRequest) (*cereal.GetWorkflowInstanceByNameResponse, error)
  • func (s *CerealService) GetWorkflowScheduleByName(ctx context.Context, req *cereal.GetWorkflowScheduleByNameRequest) (*cereal.GetWorkflowScheduleByNameResponse, error)
  • func (s *CerealService) KillWorkflow(ctx context.Context, req *cereal.KillWorkflowRequest) (*cereal.KillWorkflowResponse, error)
  • func (s *CerealService) ListWorkflowInstances(req *cereal.ListWorkflowInstancesRequest, ...) error
  • func (s *CerealService) ListWorkflowSchedules(req *cereal.ListWorkflowSchedulesRequest, ...) error
  • func (s *CerealService) UpdateWorkflowScheduleByName(ctx context.Context, req *cereal.UpdateWorkflowScheduleByNameRequest) (*cereal.UpdateWorkflowScheduleByNameResponse, error)

Variables

var BodyType = struct {
	committed string
	dequeue   string
}{
	// contains filtered or unexported fields
}

Types

type CerealService

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

func NewCerealService

func NewCerealService(ctx context.Context, b libcereal.Driver) *CerealService

func (*CerealService) CancelWorkflow

func (s *CerealService) CancelWorkflow(ctx context.Context, req *cereal.CancelWorkflowRequest) (*cereal.CancelWorkflowResponse, error)

func (*CerealService) CreateWorkflowSchedule

func (s *CerealService) CreateWorkflowSchedule(ctx context.Context, req *cereal.CreateWorkflowScheduleRequest) (*cereal.CreateWorkflowScheduleResponse, error)

func (*CerealService) DequeueTask

func (s *CerealService) DequeueTask(req cereal.CerealService_DequeueTaskServer) error

func (*CerealService) DequeueWorkflow

func (s *CerealService) DequeueWorkflow(req cereal.CerealService_DequeueWorkflowServer) error

func (*CerealService) DequeueWorkflowChunk

func (s *CerealService) DequeueWorkflowChunk(req cereal.CerealService_DequeueWorkflowChunkServer) error

func (*CerealService) EnqueueWorkflow

func (s *CerealService) EnqueueWorkflow(ctx context.Context, req *cereal.EnqueueWorkflowRequest) (*cereal.EnqueueWorkflowResponse, error)

func (*CerealService) GetWorkflowInstanceByName

func (s *CerealService) GetWorkflowInstanceByName(ctx context.Context, req *cereal.GetWorkflowInstanceByNameRequest) (*cereal.GetWorkflowInstanceByNameResponse, error)

func (*CerealService) GetWorkflowScheduleByName

func (s *CerealService) GetWorkflowScheduleByName(ctx context.Context, req *cereal.GetWorkflowScheduleByNameRequest) (*cereal.GetWorkflowScheduleByNameResponse, error)

func (*CerealService) KillWorkflow

func (s *CerealService) KillWorkflow(ctx context.Context, req *cereal.KillWorkflowRequest) (*cereal.KillWorkflowResponse, error)

func (*CerealService) ListWorkflowInstances

func (s *CerealService) ListWorkflowInstances(req *cereal.ListWorkflowInstancesRequest, resp cereal.CerealService_ListWorkflowInstancesServer) error

func (*CerealService) ListWorkflowSchedules

func (s *CerealService) ListWorkflowSchedules(req *cereal.ListWorkflowSchedulesRequest, out cereal.CerealService_ListWorkflowSchedulesServer) error

func (*CerealService) UpdateWorkflowScheduleByName

func (s *CerealService) UpdateWorkflowScheduleByName(ctx context.Context, req *cereal.UpdateWorkflowScheduleByNameRequest) (*cereal.UpdateWorkflowScheduleByNameResponse, error)