proto

package
v0.18.1 Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_helloworld_proto protoreflect.FileDescriptor

Functions

func NewCounterServer 

func NewCounterServer(srv CounterServer, opts ...sdk_go.ServiceDefinitionOption) sdk_go.ServiceDefinition

func NewGreeterServer 

func NewGreeterServer(srv GreeterServer, opts ...sdk_go.ServiceDefinitionOption) sdk_go.ServiceDefinition

func NewWorkflowServer added in v0.12.0 

func NewWorkflowServer(srv WorkflowServer, opts ...sdk_go.ServiceDefinitionOption) sdk_go.ServiceDefinition

Types

type AddRequest 

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

func (*AddRequest) Descriptor deprecated 

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

Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.

func (*AddRequest) GetDelta 

func (x *AddRequest) GetDelta() int64

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 AddWatcherRequest 

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

func (*AddWatcherRequest) Descriptor deprecated 

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

Deprecated: Use AddWatcherRequest.ProtoReflect.Descriptor instead.

func (*AddWatcherRequest) GetAwakeableId 

func (x *AddWatcherRequest) GetAwakeableId() string

func (*AddWatcherRequest) ProtoMessage 

func (*AddWatcherRequest) ProtoMessage()

func (*AddWatcherRequest) ProtoReflect 

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

func (*AddWatcherRequest) Reset 

func (x *AddWatcherRequest) Reset()

func (*AddWatcherRequest) String 

func (x *AddWatcherRequest) String() string

type AddWatcherResponse 

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

func (*AddWatcherResponse) Descriptor deprecated 

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

Deprecated: Use AddWatcherResponse.ProtoReflect.Descriptor instead.

func (*AddWatcherResponse) ProtoMessage 

func (*AddWatcherResponse) ProtoMessage()

func (*AddWatcherResponse) ProtoReflect 

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

func (*AddWatcherResponse) Reset 

func (x *AddWatcherResponse) Reset()

func (*AddWatcherResponse) String 

func (x *AddWatcherResponse) String() string

type CounterClient 

type CounterClient interface {
	// Mutate the value
	Add(opts ...sdk_go.ClientOption) sdk_go.Client[*AddRequest, *GetResponse]
	// Get the current value
	Get(opts ...sdk_go.ClientOption) sdk_go.Client[*GetRequest, *GetResponse]
	// Internal method to store an awakeable ID for the Watch method
	AddWatcher(opts ...sdk_go.ClientOption) sdk_go.Client[*AddWatcherRequest, *AddWatcherResponse]
	// Wait for the counter to change and then return the new value
	Watch(opts ...sdk_go.ClientOption) sdk_go.Client[*WatchRequest, *GetResponse]
}

CounterClient is the client API for helloworld.Counter service.

func NewCounterClient 

func NewCounterClient(ctx sdk_go.Context, key string, opts ...sdk_go.ClientOption) CounterClient

type CounterServer 

type CounterServer interface {
	// Mutate the value
	Add(ctx sdk_go.ObjectContext, req *AddRequest) (*GetResponse, error)
	// Get the current value
	Get(ctx sdk_go.ObjectSharedContext, req *GetRequest) (*GetResponse, error)
	// Internal method to store an awakeable ID for the Watch method
	AddWatcher(ctx sdk_go.ObjectContext, req *AddWatcherRequest) (*AddWatcherResponse, error)
	// Wait for the counter to change and then return the new value
	Watch(ctx sdk_go.ObjectSharedContext, req *WatchRequest) (*GetResponse, error)
}

CounterServer is the server API for helloworld.Counter service. All implementations should embed UnimplementedCounterServer for forward compatibility.

type FinishRequest added in v0.12.0 

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

func (*FinishRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use FinishRequest.ProtoReflect.Descriptor instead.

func (*FinishRequest) ProtoMessage added in v0.12.0 

func (*FinishRequest) ProtoMessage()

func (*FinishRequest) ProtoReflect added in v0.12.0 

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

func (*FinishRequest) Reset added in v0.12.0 

func (x *FinishRequest) Reset()

func (*FinishRequest) String added in v0.12.0 

func (x *FinishRequest) String() string

type FinishResponse added in v0.12.0 

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

func (*FinishResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use FinishResponse.ProtoReflect.Descriptor instead.

func (*FinishResponse) ProtoMessage added in v0.12.0 

func (*FinishResponse) ProtoMessage()

func (*FinishResponse) ProtoReflect added in v0.12.0 

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

func (*FinishResponse) Reset added in v0.12.0 

func (x *FinishResponse) Reset()

func (*FinishResponse) String added in v0.12.0 

func (x *FinishResponse) String() string

type GetRequest 

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

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() int64

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type GreeterClient 

type GreeterClient interface {
	SayHello(opts ...sdk_go.ClientOption) sdk_go.Client[*HelloRequest, *HelloResponse]
}

GreeterClient is the client API for helloworld.Greeter service.

func NewGreeterClient 

func NewGreeterClient(ctx sdk_go.Context, opts ...sdk_go.ClientOption) GreeterClient

type GreeterServer 

type GreeterServer interface {
	SayHello(ctx sdk_go.Context, req *HelloRequest) (*HelloResponse, error)
}

GreeterServer is the server API for helloworld.Greeter service. All implementations should embed UnimplementedGreeterServer for forward compatibility.

type HelloRequest 

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

func (*HelloRequest) Descriptor deprecated 

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

Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.

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"`
	// 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) 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 RunRequest added in v0.12.0 

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

func (*RunRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) ProtoMessage added in v0.12.0 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect added in v0.12.0 

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

func (*RunRequest) Reset added in v0.12.0 

func (x *RunRequest) Reset()

func (*RunRequest) String added in v0.12.0 

func (x *RunRequest) String() string

type RunResponse added in v0.12.0 

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

func (*RunResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetStatus added in v0.12.0 

func (x *RunResponse) GetStatus() string

func (*RunResponse) ProtoMessage added in v0.12.0 

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect added in v0.12.0 

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

func (*RunResponse) Reset added in v0.12.0 

func (x *RunResponse) Reset()

func (*RunResponse) String added in v0.12.0 

func (x *RunResponse) String() string

type StatusRequest added in v0.12.0 

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

func (*StatusRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage added in v0.12.0 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect added in v0.12.0 

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

func (*StatusRequest) Reset added in v0.12.0 

func (x *StatusRequest) Reset()

func (*StatusRequest) String added in v0.12.0 

func (x *StatusRequest) String() string

type StatusResponse added in v0.12.0 

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

func (*StatusResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetStatus added in v0.12.0 

func (x *StatusResponse) GetStatus() string

func (*StatusResponse) ProtoMessage added in v0.12.0 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect added in v0.12.0 

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

func (*StatusResponse) Reset added in v0.12.0 

func (x *StatusResponse) Reset()

func (*StatusResponse) String added in v0.12.0 

func (x *StatusResponse) String() string

type Test added in v0.18.0 

type Test struct {
	Inner        *Test         `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"`
	Primitive    string        `protobuf:"bytes,2,opt,name=primitive,proto3" json:"primitive,omitempty"`
	AnotherInner *WatchRequest `protobuf:"bytes,3,opt,name=another_inner,json=anotherInner,proto3" json:"another_inner,omitempty"`
	// contains filtered or unexported fields
}

func (*Test) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use Test.ProtoReflect.Descriptor instead.

func (*Test) GetAnotherInner added in v0.18.0 

func (x *Test) GetAnotherInner() *WatchRequest

func (*Test) GetInner added in v0.18.0 

func (x *Test) GetInner() *Test

func (*Test) GetPrimitive added in v0.18.0 

func (x *Test) GetPrimitive() string

func (*Test) ProtoMessage added in v0.18.0 

func (*Test) ProtoMessage()

func (*Test) ProtoReflect added in v0.18.0 

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

func (*Test) Reset added in v0.18.0 

func (x *Test) Reset()

func (*Test) String added in v0.18.0 

func (x *Test) String() string

type UnimplementedCounterServer 

type UnimplementedCounterServer struct{}

UnimplementedCounterServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCounterServer) Add 

func (UnimplementedCounterServer) Add(ctx sdk_go.ObjectContext, req *AddRequest) (*GetResponse, error)

func (UnimplementedCounterServer) AddWatcher 

func (UnimplementedCounterServer) AddWatcher(ctx sdk_go.ObjectContext, req *AddWatcherRequest) (*AddWatcherResponse, error)

func (UnimplementedCounterServer) Get 

func (UnimplementedCounterServer) Get(ctx sdk_go.ObjectSharedContext, req *GetRequest) (*GetResponse, error)

func (UnimplementedCounterServer) Watch 

func (UnimplementedCounterServer) Watch(ctx sdk_go.ObjectSharedContext, req *WatchRequest) (*GetResponse, error)

type UnimplementedGreeterServer 

type UnimplementedGreeterServer struct{}

UnimplementedGreeterServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedGreeterServer) SayHello 

func (UnimplementedGreeterServer) SayHello(ctx sdk_go.Context, req *HelloRequest) (*HelloResponse, error)

type UnimplementedWorkflowServer added in v0.12.0 

type UnimplementedWorkflowServer struct{}

UnimplementedWorkflowServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedWorkflowServer) Finish added in v0.12.0 

func (UnimplementedWorkflowServer) Finish(ctx sdk_go.WorkflowSharedContext, req *FinishRequest) (*FinishResponse, error)

func (UnimplementedWorkflowServer) Run added in v0.12.0 

func (UnimplementedWorkflowServer) Run(ctx sdk_go.WorkflowContext, req *RunRequest) (*RunResponse, error)

func (UnimplementedWorkflowServer) Status added in v0.12.0 

func (UnimplementedWorkflowServer) Status(ctx sdk_go.WorkflowSharedContext, req *StatusRequest) (*StatusResponse, error)

type UnsafeCounterServer 

type UnsafeCounterServer interface {
	// contains filtered or unexported methods
}

UnsafeCounterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CounterServer will result in compilation errors.

type UnsafeGreeterServer 

type UnsafeGreeterServer interface {
	// contains filtered or unexported methods
}

UnsafeGreeterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GreeterServer will result in compilation errors.

type UnsafeWorkflowServer added in v0.12.0 

type UnsafeWorkflowServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkflowServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkflowServer will result in compilation errors.

type WatchRequest 

type WatchRequest struct {
	TimeoutMillis int64 `protobuf:"varint,1,opt,name=timeout_millis,json=timeoutMillis,proto3" json:"timeout_millis,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRequest) Descriptor deprecated 

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetTimeoutMillis 

func (x *WatchRequest) GetTimeoutMillis() int64

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

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

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) String 

func (x *WatchRequest) String() string

type WorkflowClient added in v0.12.0 

type WorkflowClient interface {
	// Execute the workflow
	Run(opts ...sdk_go.ClientOption) sdk_go.Client[*RunRequest, *RunResponse]
	// Unblock the workflow
	Finish(opts ...sdk_go.ClientOption) sdk_go.Client[*FinishRequest, *FinishResponse]
	// Check the current status
	Status(opts ...sdk_go.ClientOption) sdk_go.Client[*StatusRequest, *StatusResponse]
}

WorkflowClient is the client API for helloworld.Workflow service.

func NewWorkflowClient added in v0.12.0 

func NewWorkflowClient(ctx sdk_go.Context, workflowID string, opts ...sdk_go.ClientOption) WorkflowClient

type WorkflowServer added in v0.12.0 

type WorkflowServer interface {
	// Execute the workflow
	Run(ctx sdk_go.WorkflowContext, req *RunRequest) (*RunResponse, error)
	// Unblock the workflow
	Finish(ctx sdk_go.WorkflowSharedContext, req *FinishRequest) (*FinishResponse, error)
	// Check the current status
	Status(ctx sdk_go.WorkflowSharedContext, req *StatusRequest) (*StatusResponse, error)
}

WorkflowServer is the server API for helloworld.Workflow service. All implementations should embed UnimplementedWorkflowServer for forward compatibility.

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.