Help us shape the future of Go! Take the 2026 Go Developer Survey

core_sync_node

package
v0.57.29 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RuntimeMessage_Kind_name = map[int32]string{
		0: "KIND_UNKNOWN",
		1: "READY",
		2: "OPEN_STREAM",
		3: "CLOSE",
		4: "CLOSED",
		5: "FAILED",
	}
	RuntimeMessage_Kind_value = map[string]int32{
		"KIND_UNKNOWN": 0,
		"READY":        1,
		"OPEN_STREAM":  2,
		"CLOSE":        3,
		"CLOSED":       4,
		"FAILED":       5,
	}
)

Enum value maps for RuntimeMessage_Kind.

Functions

This section is empty.

Types

type RuntimeInit 

type RuntimeInit struct {

	// Directory is the filesystem path exclusively owned until the Worker exits.
	Directory string `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	// contains filtered or unexported fields
}

RuntimeInit selects the exclusively owned storage directory for one Worker.

func (*RuntimeInit) CloneMessageVT 

func (m *RuntimeInit) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*RuntimeInit) CloneVT 

func (m *RuntimeInit) CloneVT() *RuntimeInit

func (*RuntimeInit) EqualMessageVT 

func (this *RuntimeInit) EqualMessageVT(thatMsg any) bool

func (*RuntimeInit) EqualVT 

func (this *RuntimeInit) EqualVT(that *RuntimeInit) bool

func (*RuntimeInit) GetDirectory 

func (x *RuntimeInit) GetDirectory() string

func (*RuntimeInit) MarshalJSON 

func (x *RuntimeInit) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RuntimeInit to JSON.

func (*RuntimeInit) MarshalProtoJSON 

func (x *RuntimeInit) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RuntimeInit message to JSON.

func (*RuntimeInit) MarshalProtoText 

func (x *RuntimeInit) MarshalProtoText() string

func (*RuntimeInit) MarshalToSizedBufferVT 

func (m *RuntimeInit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeInit) MarshalToVT 

func (m *RuntimeInit) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeInit) MarshalVT 

func (m *RuntimeInit) MarshalVT() (dAtA []byte, err error)

func (*RuntimeInit) ProtoMessage 

func (*RuntimeInit) ProtoMessage()

func (*RuntimeInit) Reset 

func (x *RuntimeInit) Reset()

func (*RuntimeInit) SizeVT 

func (m *RuntimeInit) SizeVT() (n int)

func (*RuntimeInit) String 

func (x *RuntimeInit) String() string

func (*RuntimeInit) UnmarshalJSON 

func (x *RuntimeInit) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RuntimeInit from JSON.

func (*RuntimeInit) UnmarshalProtoJSON 

func (x *RuntimeInit) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RuntimeInit message from JSON.

func (*RuntimeInit) UnmarshalVT 

func (m *RuntimeInit) UnmarshalVT(dAtA []byte) error

type RuntimeMessage 

type RuntimeMessage struct {

	// Kind selects the required operation or response.
	Kind RuntimeMessage_Kind `protobuf:"varint,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// Error describes a failure in FAILED or CLOSED and is empty on success.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

RuntimeMessage controls the Worker lifetime outside its Resource connection. OPEN_STREAM accompanies a transferred MessagePort carrying StaRPC packets.

func (*RuntimeMessage) CloneMessageVT 

func (m *RuntimeMessage) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*RuntimeMessage) CloneVT 

func (m *RuntimeMessage) CloneVT() *RuntimeMessage

func (*RuntimeMessage) EqualMessageVT 

func (this *RuntimeMessage) EqualMessageVT(thatMsg any) bool

func (*RuntimeMessage) EqualVT 

func (this *RuntimeMessage) EqualVT(that *RuntimeMessage) bool

func (*RuntimeMessage) GetError 

func (x *RuntimeMessage) GetError() string

func (*RuntimeMessage) GetKind 

func (x *RuntimeMessage) GetKind() RuntimeMessage_Kind

func (*RuntimeMessage) MarshalJSON 

func (x *RuntimeMessage) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RuntimeMessage to JSON.

func (*RuntimeMessage) MarshalProtoJSON 

func (x *RuntimeMessage) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RuntimeMessage message to JSON.

func (*RuntimeMessage) MarshalProtoText 

func (x *RuntimeMessage) MarshalProtoText() string

func (*RuntimeMessage) MarshalToSizedBufferVT 

func (m *RuntimeMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RuntimeMessage) MarshalToVT 

func (m *RuntimeMessage) MarshalToVT(dAtA []byte) (int, error)

func (*RuntimeMessage) MarshalVT 

func (m *RuntimeMessage) MarshalVT() (dAtA []byte, err error)

func (*RuntimeMessage) ProtoMessage 

func (*RuntimeMessage) ProtoMessage()

func (*RuntimeMessage) Reset 

func (x *RuntimeMessage) Reset()

func (*RuntimeMessage) SizeVT 

func (m *RuntimeMessage) SizeVT() (n int)

func (*RuntimeMessage) String 

func (x *RuntimeMessage) String() string

func (*RuntimeMessage) UnmarshalJSON 

func (x *RuntimeMessage) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RuntimeMessage from JSON.

func (*RuntimeMessage) UnmarshalProtoJSON 

func (x *RuntimeMessage) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RuntimeMessage message from JSON.

func (*RuntimeMessage) UnmarshalVT 

func (m *RuntimeMessage) UnmarshalVT(dAtA []byte) error

type RuntimeMessage_Kind 

type RuntimeMessage_Kind int32

Kind identifies the required Worker lifecycle operation or response. 

const (
	// KIND_UNKNOWN is invalid for every lifecycle operation.
	RuntimeMessage_KIND_UNKNOWN RuntimeMessage_Kind = 0
	// READY confirms the World is open and accepts Resource streams.
	RuntimeMessage_READY RuntimeMessage_Kind = 1
	// OPEN_STREAM supplies one transferred MessagePort for a StaRPC exchange.
	RuntimeMessage_OPEN_STREAM RuntimeMessage_Kind = 2
	// CLOSE stops admission and requests a durable, joined shutdown.
	RuntimeMessage_CLOSE RuntimeMessage_Kind = 3
	// CLOSED reports completion of shutdown, including any failure.
	RuntimeMessage_CLOSED RuntimeMessage_Kind = 4
	// FAILED reports a startup, protocol, or panic failure that ends the runtime.
	RuntimeMessage_FAILED RuntimeMessage_Kind = 5
)

func (RuntimeMessage_Kind) Enum 

func (x RuntimeMessage_Kind) Enum() *RuntimeMessage_Kind

func (RuntimeMessage_Kind) MarshalJSON 

func (x RuntimeMessage_Kind) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RuntimeMessage_Kind to JSON.

func (RuntimeMessage_Kind) MarshalProtoJSON 

func (x RuntimeMessage_Kind) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RuntimeMessage_Kind to JSON.

func (RuntimeMessage_Kind) MarshalProtoText 

func (x RuntimeMessage_Kind) MarshalProtoText() string

func (RuntimeMessage_Kind) MarshalText 

func (x RuntimeMessage_Kind) MarshalText() ([]byte, error)

MarshalText marshals the RuntimeMessage_Kind to text.

func (RuntimeMessage_Kind) String 

func (x RuntimeMessage_Kind) String() string

func (*RuntimeMessage_Kind) UnmarshalJSON 

func (x *RuntimeMessage_Kind) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RuntimeMessage_Kind from JSON.

func (*RuntimeMessage_Kind) UnmarshalProtoJSON 

func (x *RuntimeMessage_Kind) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RuntimeMessage_Kind from JSON.

func (*RuntimeMessage_Kind) UnmarshalText 

func (x *RuntimeMessage_Kind) UnmarshalText(b []byte) error

UnmarshalText unmarshals the RuntimeMessage_Kind from text.

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.