Documentation ¶
Index ¶
- Variables
- func CreateInitServerFn(ps *Workflow) rpc.InitServer
- type Workflow
- func (s *Workflow) ActionDoc(_ context.Context, payload *pb.WorkflowRequest) (*pb.WorkflowReply, error)
- func (s *Workflow) CreateTrigger(ctx context.Context, payload *pb.TriggerRequest) (*pb.StateReply, error)
- func (s *Workflow) CronTrigger(ctx context.Context, _ *pb.TriggerRequest) (*pb.WorkflowReply, error)
- func (s *Workflow) DeleteTrigger(ctx context.Context, payload *pb.TriggerRequest) (*pb.StateReply, error)
- func (s *Workflow) ListWebhook(ctx context.Context, _ *pb.WorkflowRequest) (*pb.WebhooksReply, error)
- func (s *Workflow) RunAction(ctx context.Context, payload *pb.WorkflowRequest) (*pb.WorkflowReply, error)
- func (s *Workflow) SyntaxCheck(_ context.Context, payload *pb.WorkflowRequest) (*pb.StateReply, error)
- func (s *Workflow) WebhookTrigger(ctx context.Context, payload *pb.TriggerRequest) (*pb.WorkflowReply, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewWorkflow, CreateInitServerFn)
Functions ¶
func CreateInitServerFn ¶ added in v0.0.24
func CreateInitServerFn(ps *Workflow) rpc.InitServer
Types ¶
type Workflow ¶
type Workflow struct {
// contains filtered or unexported fields
}
func NewWorkflow ¶
func NewWorkflow( bus event.Bus, rdb *redis.Client, repo repository.WorkflowRepository, message pb.MessageSvcClient, middle pb.MiddleSvcClient, logger log.Logger) *Workflow
func (*Workflow) ActionDoc ¶ added in v0.0.19
func (s *Workflow) ActionDoc(_ context.Context, payload *pb.WorkflowRequest) (*pb.WorkflowReply, error)
func (*Workflow) CreateTrigger ¶ added in v0.0.18
func (s *Workflow) CreateTrigger(ctx context.Context, payload *pb.TriggerRequest) (*pb.StateReply, error)
func (*Workflow) CronTrigger ¶ added in v0.0.18
func (s *Workflow) CronTrigger(ctx context.Context, _ *pb.TriggerRequest) (*pb.WorkflowReply, error)
func (*Workflow) DeleteTrigger ¶ added in v0.0.18
func (s *Workflow) DeleteTrigger(ctx context.Context, payload *pb.TriggerRequest) (*pb.StateReply, error)
func (*Workflow) ListWebhook ¶ added in v0.1.1
func (s *Workflow) ListWebhook(ctx context.Context, _ *pb.WorkflowRequest) (*pb.WebhooksReply, error)
func (*Workflow) RunAction ¶ added in v0.0.16
func (s *Workflow) RunAction(ctx context.Context, payload *pb.WorkflowRequest) (*pb.WorkflowReply, error)
func (*Workflow) SyntaxCheck ¶ added in v0.0.18
func (s *Workflow) SyntaxCheck(_ context.Context, payload *pb.WorkflowRequest) (*pb.StateReply, error)
func (*Workflow) WebhookTrigger ¶ added in v0.0.18
func (s *Workflow) WebhookTrigger(ctx context.Context, payload *pb.TriggerRequest) (*pb.WorkflowReply, error)
Click to show internal directories.
Click to hide internal directories.