demopb

Documentation

Index

• Variables
• func RegisterDemoWorker(w worker.Worker, wrk DemoWorker)
• type DemoClient
  • func NewDemoClient(client client.Client) *DemoClient
  • func (clt *DemoClient) HelloWorld(ctx context.Context, options client.StartWorkflowOptions, ...) (DemoWorkflowRun[HelloWorldResponse], error)
• type DemoWorker
• type DemoWorkflowRun
  • func (wr *DemoWorkflowRun[T]) Get(ctx context.Context, valuePtr *T) error
  • func (wr *DemoWorkflowRun[T]) GetWithOptions(ctx context.Context, res *T, options client.WorkflowRunGetOptions) error
• type HelloWorldRequest
  • func (*HelloWorldRequest) Descriptor() ([]byte, []int)
  • func (x *HelloWorldRequest) GetName() string
  • func (*HelloWorldRequest) ProtoMessage()
  • func (x *HelloWorldRequest) ProtoReflect() protoreflect.Message
  • func (x *HelloWorldRequest) Reset()
  • func (x *HelloWorldRequest) String() string
• type HelloWorldResponse
  • func (*HelloWorldResponse) Descriptor() ([]byte, []int)
  • func (x *HelloWorldResponse) GetMessage() string
  • func (*HelloWorldResponse) ProtoMessage()
  • func (x *HelloWorldResponse) ProtoReflect() protoreflect.Message
  • func (x *HelloWorldResponse) Reset()
  • func (x *HelloWorldResponse) String() string
• type UnimplementedDemoWorker
  • func (wrk *UnimplementedDemoWorker) HelloWorld(ctx workflow.Context, req *HelloWorldRequest) (*HelloWorldResponse, error)

Variables

var File_demo_proto protoreflect.FileDescriptor

Functions

func RegisterDemoWorker

func RegisterDemoWorker(w worker.Worker, wrk DemoWorker)

Types

type DemoClient

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

func NewDemoClient

func NewDemoClient(client client.Client) *DemoClient

func (*DemoClient) HelloWorld

func (clt *DemoClient) HelloWorld(ctx context.Context, options client.StartWorkflowOptions, req *HelloWorldRequest) (DemoWorkflowRun[HelloWorldResponse], error)

type DemoWorker

type DemoWorker interface {
	HelloWorld(ctx workflow.Context, req *HelloWorldRequest) (*HelloWorldResponse, error)
}

type DemoWorkflowRun

type DemoWorkflowRun[T any] struct {
	client.WorkflowRun
}

func (*DemoWorkflowRun[T]) Get

func (wr *DemoWorkflowRun[T]) Get(ctx context.Context, valuePtr *T) error

func (*DemoWorkflowRun[T]) GetWithOptions

func (wr *DemoWorkflowRun[T]) GetWithOptions(ctx context.Context, res *T, options client.WorkflowRunGetOptions) error

type HelloWorldRequest

type HelloWorldRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*HelloWorldRequest) Descriptor

func (*HelloWorldRequest) Descriptor() ([]byte, []int)

Deprecated: Use HelloWorldRequest.ProtoReflect.Descriptor instead.

func (*HelloWorldRequest) GetName

func (x *HelloWorldRequest) GetName() string

func (*HelloWorldRequest) ProtoMessage

func (*HelloWorldRequest) ProtoMessage()

func (*HelloWorldRequest) ProtoReflect

func (x *HelloWorldRequest) ProtoReflect() protoreflect.Message

func (*HelloWorldRequest) Reset

func (x *HelloWorldRequest) Reset()

func (*HelloWorldRequest) String

func (x *HelloWorldRequest) String() string

type HelloWorldResponse

type HelloWorldResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HelloWorldResponse) Descriptor

func (*HelloWorldResponse) Descriptor() ([]byte, []int)

Deprecated: Use HelloWorldResponse.ProtoReflect.Descriptor instead.

func (*HelloWorldResponse) GetMessage

func (x *HelloWorldResponse) GetMessage() string

func (*HelloWorldResponse) ProtoMessage

func (*HelloWorldResponse) ProtoMessage()

func (*HelloWorldResponse) ProtoReflect

func (x *HelloWorldResponse) ProtoReflect() protoreflect.Message

func (*HelloWorldResponse) Reset

func (x *HelloWorldResponse) Reset()

func (*HelloWorldResponse) String

func (x *HelloWorldResponse) String() string

type UnimplementedDemoWorker

type UnimplementedDemoWorker struct {
}

func (*UnimplementedDemoWorker) HelloWorld

func (wrk *UnimplementedDemoWorker) HelloWorld(ctx workflow.Context, req *HelloWorldRequest) (*HelloWorldResponse, error)