proto

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

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]
}

type CounterIngressClient interface {
	// Mutate the value
	Add() ingress.Requester[*AddRequest, *GetResponse]
	// Get the current value
	Get() ingress.Requester[*GetRequest, *GetResponse]
}

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)
}

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

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

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

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

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

type GreeterIngressClient interface {
	SayHello() ingress.Requester[*HelloRequest, *HelloResponse]
}

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

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

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

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

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

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

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

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 *StatusResponse `protobuf:"bytes,3,opt,name=another_inner,json=anotherInner,proto3" json:"another_inner,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedCounterServer struct{}

type UnimplementedGreeterServer struct{}

type UnimplementedWorkflowServer struct{}

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

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

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

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]
}

type WorkflowIngressClient interface {
	// Execute the workflow
	Submit(ctx context.Context, input *RunRequest, opts ...ingress.SendOption) (ingress.SendResponse[*RunResponse], error)
	// Handle creates an handle to the submitted workflow, useful to retrieve its output or attach to it
	Handle() ingress.InvocationHandle[*RunResponse]
	// Unblock the workflow
	Finish() ingress.Requester[*FinishRequest, *FinishResponse]
	// Check the current status
	Status() ingress.Requester[*StatusRequest, *StatusResponse]
}

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)
}