api

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AddActivity_Add_ActitityType = "/golemporal.example.api.AddActivity/Add"
)
View Source 
var File_api_example_proto protoreflect.FileDescriptor
View Source 
var (
	GoodbyeWorkflow_Goodbye_WorkflowType = "/golemporal.example.api.GoodbyeWorkflow/Goodbye"
)
View Source 
var (
	HelloWorkflow_Hello_WorkflowType = "/golemporal.example.api.HelloWorkflow/Hello"
)
View Source 
var (
	MultiActivity_Multi_ActitityType = "/golemporal.example.api.MultiActivity/Multi"
)

Functions

func RegisterAddActivity added in v0.1.0 

func RegisterAddActivity(
	wk worker.Worker,
	server AddActivityServer,
)

func RegisterGoodbyeWorkflow added in v0.1.0 

func RegisterGoodbyeWorkflow(
	wk worker.Worker,
	server GoodbyeWorkflowServer,
)

func RegisterHelloWorkflow added in v0.1.0 

func RegisterHelloWorkflow(
	wk worker.Worker,
	server HelloWorkflowServer,
)

func RegisterMultiActivity added in v0.1.0 

func RegisterMultiActivity(
	wk worker.Worker,
	server MultiActivityServer,
)

Types

type AddActivityClient 

type AddActivityClient interface {
	Add(ctx workflow.Context, in *AddRequest) (*AddResponse, error)
}

func NewAddActivityClient 

func NewAddActivityClient() AddActivityClient

type AddActivityServer 

type AddActivityServer interface {
	Add(context.Context, *AddRequest) (*AddResponse, error)
}

type AddRequest 

type AddRequest struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRequest) Descriptor deprecated 

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

Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.

func (*AddRequest) GetCount 

func (x *AddRequest) GetCount() int32

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) ProtoReflect 

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

func (*AddRequest) Reset 

func (x *AddRequest) Reset()

func (*AddRequest) String 

func (x *AddRequest) String() string

type AddResponse 

type AddResponse struct {
	Result int32 `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*AddResponse) Descriptor deprecated 

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

Deprecated: Use AddResponse.ProtoReflect.Descriptor instead.

func (*AddResponse) GetResult 

func (x *AddResponse) GetResult() int32

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) ProtoReflect 

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

func (*AddResponse) Reset 

func (x *AddResponse) Reset()

func (*AddResponse) String 

func (x *AddResponse) String() string

type GoodbyeRequest 

type GoodbyeRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Count int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GoodbyeRequest) Descriptor deprecated 

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

Deprecated: Use GoodbyeRequest.ProtoReflect.Descriptor instead.

func (*GoodbyeRequest) GetCount 

func (x *GoodbyeRequest) GetCount() int32

func (*GoodbyeRequest) GetName 

func (x *GoodbyeRequest) GetName() string

func (*GoodbyeRequest) ProtoMessage 

func (*GoodbyeRequest) ProtoMessage()

func (*GoodbyeRequest) ProtoReflect 

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

func (*GoodbyeRequest) Reset 

func (x *GoodbyeRequest) Reset()

func (*GoodbyeRequest) String 

func (x *GoodbyeRequest) String() string

type GoodbyeResponse 

type GoodbyeResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Result  int32  `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GoodbyeResponse) Descriptor deprecated 

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

Deprecated: Use GoodbyeResponse.ProtoReflect.Descriptor instead.

func (*GoodbyeResponse) GetMessage 

func (x *GoodbyeResponse) GetMessage() string

func (*GoodbyeResponse) GetResult 

func (x *GoodbyeResponse) GetResult() int32

func (*GoodbyeResponse) ProtoMessage 

func (*GoodbyeResponse) ProtoMessage()

func (*GoodbyeResponse) ProtoReflect 

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

func (*GoodbyeResponse) Reset 

func (x *GoodbyeResponse) Reset()

func (*GoodbyeResponse) String 

func (x *GoodbyeResponse) String() string

type GoodbyeWorkflowClient added in v0.1.0 

type GoodbyeWorkflowClient interface {
	Goodbye(ctx context.Context, in *GoodbyeRequest, opts ...starter.Option) (*GoodbyeResponse, *protobuf.Metadata, error)
}

func NewGoodbyeWorkflowClient added in v0.1.0 

func NewGoodbyeWorkflowClient(c client.Client, taskQueue string) GoodbyeWorkflowClient

type GoodbyeWorkflowServer added in v0.1.0 

type GoodbyeWorkflowServer interface {
	Goodbye(workflow.Context, *GoodbyeRequest) (*GoodbyeResponse, error)
}

type HelloRequest 

type HelloRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Count int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*HelloRequest) Descriptor deprecated 

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

Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.

func (*HelloRequest) GetCount 

func (x *HelloRequest) GetCount() int32

func (*HelloRequest) GetName 

func (x *HelloRequest) GetName() string

func (*HelloRequest) ProtoMessage 

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) ProtoReflect 

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

func (*HelloRequest) Reset 

func (x *HelloRequest) Reset()

func (*HelloRequest) String 

func (x *HelloRequest) String() string

type HelloResponse 

type HelloResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Result  int32  `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*HelloResponse) Descriptor deprecated 

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

Deprecated: Use HelloResponse.ProtoReflect.Descriptor instead.

func (*HelloResponse) GetMessage 

func (x *HelloResponse) GetMessage() string

func (*HelloResponse) GetResult 

func (x *HelloResponse) GetResult() int32

func (*HelloResponse) ProtoMessage 

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) ProtoReflect 

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

func (*HelloResponse) Reset 

func (x *HelloResponse) Reset()

func (*HelloResponse) String 

func (x *HelloResponse) String() string

type HelloWorkflowClient added in v0.1.0 

type HelloWorkflowClient interface {
	Hello(ctx context.Context, in *HelloRequest, opts ...starter.Option) (*HelloResponse, *protobuf.Metadata, error)
}

func NewHelloWorkflowClient added in v0.1.0 

func NewHelloWorkflowClient(c client.Client, taskQueue string) HelloWorkflowClient

type HelloWorkflowServer added in v0.1.0 

type HelloWorkflowServer interface {
	Hello(workflow.Context, *HelloRequest) (*HelloResponse, error)
}

type MultiActivityClient 

type MultiActivityClient interface {
	Multi(ctx workflow.Context, in *MultiRequest) (*MultiResponse, error)
}

func NewMultiActivityClient 

func NewMultiActivityClient() MultiActivityClient

type MultiActivityServer 

type MultiActivityServer interface {
	Multi(context.Context, *MultiRequest) (*MultiResponse, error)
}

type MultiRequest 

type MultiRequest struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiRequest) Descriptor deprecated 

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

Deprecated: Use MultiRequest.ProtoReflect.Descriptor instead.

func (*MultiRequest) GetCount 

func (x *MultiRequest) GetCount() int32

func (*MultiRequest) ProtoMessage 

func (*MultiRequest) ProtoMessage()

func (*MultiRequest) ProtoReflect 

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

func (*MultiRequest) Reset 

func (x *MultiRequest) Reset()

func (*MultiRequest) String 

func (x *MultiRequest) String() string

type MultiResponse 

type MultiResponse struct {
	Result int32 `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiResponse) Descriptor deprecated 

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

Deprecated: Use MultiResponse.ProtoReflect.Descriptor instead.

func (*MultiResponse) GetResult 

func (x *MultiResponse) GetResult() int32

func (*MultiResponse) ProtoMessage 

func (*MultiResponse) ProtoMessage()

func (*MultiResponse) ProtoReflect 

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

func (*MultiResponse) Reset 

func (x *MultiResponse) Reset()

func (*MultiResponse) String 

func (x *MultiResponse) String() string

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.