proto

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() ([]byte, []int)

func (x *AddRequest) GetDelta() int64

func (*AddRequest) ProtoMessage()

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

func (x *AddRequest) Reset()

func (x *AddRequest) 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]
}

CounterClient is the client API for helloworld.Counter service.

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

type CounterIngressClient ¶ added in v0.21.0

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

CounterIngressClient is the ingress client API for helloworld.Counter service.

This client is used to call the service from outside of a Restate context.

func NewCounterIngressClient(client *ingress.Client, key string) CounterIngressClient

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

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() ([]byte, []int)

func (*FinishRequest) ProtoMessage()

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

func (x *FinishRequest) Reset()

func (x *FinishRequest) String() string

type FinishResponse ¶ added in v0.12.0

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

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

func (*FinishResponse) ProtoMessage()

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

func (x *FinishResponse) Reset()

func (x *FinishResponse) String() string

type GetRequest ¶

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

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

func (*GetRequest) ProtoMessage()

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

func (x *GetRequest) Reset()

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() ([]byte, []int)

func (x *GetResponse) GetValue() int64

func (*GetResponse) ProtoMessage()

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

func (x *GetResponse) Reset()

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(ctx sdk_go.Context, opts ...sdk_go.ClientOption) GreeterClient

type GreeterIngressClient ¶ added in v0.21.0

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

GreeterIngressClient is the ingress client API for helloworld.Greeter service.

This client is used to call the service from outside of a Restate context.

func NewGreeterIngressClient(client *ingress.Client) GreeterIngressClient

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() ([]byte, []int)

func (x *HelloRequest) GetName() string

func (*HelloRequest) ProtoMessage()

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

func (x *HelloRequest) Reset()

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() ([]byte, []int)

func (x *HelloResponse) GetMessage() string

func (*HelloResponse) ProtoMessage()

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

func (x *HelloResponse) Reset()

func (x *HelloResponse) String() string

type RunRequest ¶ added in v0.12.0

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

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

func (*RunRequest) ProtoMessage()

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

func (x *RunRequest) Reset()

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() ([]byte, []int)

func (x *RunResponse) GetStatus() string

func (*RunResponse) ProtoMessage()

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

func (x *RunResponse) Reset()

func (x *RunResponse) String() string

type StatusRequest ¶ added in v0.12.0

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

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

func (*StatusRequest) ProtoMessage()

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

func (x *StatusRequest) Reset()

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() ([]byte, []int)

func (x *StatusResponse) GetStatus() string

func (*StatusResponse) ProtoMessage()

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

func (x *StatusResponse) Reset()

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

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

func (x *Test) GetAnotherInner() *StatusResponse

func (x *Test) GetInner() *Test

func (x *Test) GetPrimitive() string

func (*Test) ProtoMessage()

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

func (x *Test) Reset()

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(ctx sdk_go.ObjectContext, req *AddRequest) (*GetResponse, error)

func (UnimplementedCounterServer) Get(ctx sdk_go.ObjectSharedContext, req *GetRequest) (*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(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(ctx sdk_go.WorkflowSharedContext, req *FinishRequest) (*FinishResponse, error)

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

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 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(ctx sdk_go.Context, workflowID string, opts ...sdk_go.ClientOption) WorkflowClient

type WorkflowIngressClient ¶ added in v0.21.0

type WorkflowIngressClient interface {
	// Execute the workflow
	Submit(ctx context.Context, input *RunRequest, opts ...sdk_go.IngressSendOption) (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]
}

WorkflowIngressClient is the ingress client API for helloworld.Workflow service.

This client is used to call the service from outside of a Restate context.

func NewWorkflowIngressClient(client *ingress.Client, workflowID string) WorkflowIngressClient

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.