service

Documentation

Index

• type Workflow
  • func NewWorkflow(etcd *clientv3.Client, midClient pb.MiddleClient) *Workflow
  • func (s *Workflow) Run(ctx context.Context, payload *pb.WorkflowRequest) (*pb.WorkflowReply, error)

Types

type Workflow

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

func NewWorkflow

func NewWorkflow(etcd *clientv3.Client, midClient pb.MiddleClient) *Workflow

func (*Workflow) Run

func (s *Workflow) Run(ctx context.Context, payload *pb.WorkflowRequest) (*pb.WorkflowReply, error)