service

Documentation

Index

• type Workflow
  • func NewWorkflow(etcd *clientv3.Client, midClient pb.MiddleClient, msgClient pb.MessageClient) *Workflow
  • func (s *Workflow) Run(_ 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, msgClient pb.MessageClient) *Workflow

func (*Workflow) Run

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