service

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 24, 2021 License: MIT Imports: 17 Imported by: 0

Documentation

Index

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.