internal

package
v0.13.2 Latest Latest
Warning

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

Go to latest
Published: Dec 11, 2024 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Endpoint

type Endpoint struct {
	ProtocolMode       ProtocolMode `json:"protocolMode"`
	MinProtocolVersion int32        `json:"minProtocolVersion"`
	MaxProtocolVersion int32        `json:"maxProtocolVersion"`
	Services           []Service    `json:"services"`
}

type Handler

type Handler struct {
	Name string `json:"name,omitempty"`
	// If unspecified, defaults to EXCLUSIVE for Virtual Object. This should be unset for Services.
	Ty     *ServiceHandlerType     `json:"ty,omitempty"`
	Input  *encoding.InputPayload  `json:"input,omitempty"`
	Output *encoding.OutputPayload `json:"output,omitempty"`
}

type ProtocolMode

type ProtocolMode string
const (
	ProtocolMode_BIDI_STREAM      ProtocolMode = "BIDI_STREAM"
	ProtocolMode_REQUEST_RESPONSE ProtocolMode = "REQUEST_RESPONSE"
)

type Service

type Service struct {
	Name     string      `json:"name"`
	Ty       ServiceType `json:"ty"`
	Handlers []Handler   `json:"handlers"`
}

type ServiceHandlerType

type ServiceHandlerType string
const (
	ServiceHandlerType_WORKFLOW  ServiceHandlerType = "WORKFLOW"
	ServiceHandlerType_EXCLUSIVE ServiceHandlerType = "EXCLUSIVE"
	ServiceHandlerType_SHARED    ServiceHandlerType = "SHARED"
)

type ServiceType

type ServiceType string
const (
	ServiceType_VIRTUAL_OBJECT ServiceType = "VIRTUAL_OBJECT"
	ServiceType_SERVICE        ServiceType = "SERVICE"
	ServiceType_WORKFLOW       ServiceType = "WORKFLOW"
)

Directories

Path Synopsis
wire implements the grpc wire protocol that is used later on by the state machine to communicate with restate runtime.
wire implements the grpc wire protocol that is used later on by the state machine to communicate with restate runtime.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL