s4wave_process

package
v0.50.0 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCPersistentExecutionServiceServiceID = "s4wave.process.PersistentExecutionService"

Variables

View Source 
var (
	ProcessBindingState_name = map[int32]string{
		0: "ProcessBindingState_UNAPPROVED",
		1: "ProcessBindingState_APPROVED",
	}
	ProcessBindingState_value = map[string]int32{
		"ProcessBindingState_UNAPPROVED": 0,
		"ProcessBindingState_APPROVED":   1,
	}
)

Enum value maps for ProcessBindingState.

View Source 
var (
	ExecutionState_name = map[int32]string{
		0: "ExecutionState_STARTING",
		1: "ExecutionState_RUNNING",
		2: "ExecutionState_STOPPING",
		3: "ExecutionState_STOPPED",
		4: "ExecutionState_ERROR",
	}
	ExecutionState_value = map[string]int32{
		"ExecutionState_STARTING": 0,
		"ExecutionState_RUNNING":  1,
		"ExecutionState_STOPPING": 2,
		"ExecutionState_STOPPED":  3,
		"ExecutionState_ERROR":    4,
	}
)

Enum value maps for ExecutionState.

Functions

func NewSRPCPersistentExecutionServiceHandler 

func NewSRPCPersistentExecutionServiceHandler(impl SRPCPersistentExecutionServiceServer, serviceID string) srpc.Handler

NewSRPCPersistentExecutionServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.process.PersistentExecutionService

func SRPCRegisterPersistentExecutionService 

func SRPCRegisterPersistentExecutionService(mux srpc.Mux, impl SRPCPersistentExecutionServiceServer) error

SRPCRegisterPersistentExecutionService registers the implementation with the mux. Uses the default serviceID: s4wave.process.PersistentExecutionService

Types

type ExecuteRequest 

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

ExecuteRequest is the request to start a persistent process.

func (*ExecuteRequest) CloneMessageVT 

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

func (*ExecuteRequest) CloneVT 

func (m *ExecuteRequest) CloneVT() *ExecuteRequest

func (*ExecuteRequest) EqualMessageVT 

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

func (*ExecuteRequest) EqualVT 

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

func (*ExecuteRequest) MarshalJSON 

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

MarshalJSON marshals the ExecuteRequest to JSON.

func (*ExecuteRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ExecuteRequest message to JSON.

func (*ExecuteRequest) MarshalProtoText 

func (x *ExecuteRequest) MarshalProtoText() string

func (*ExecuteRequest) MarshalToSizedBufferVT 

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

func (*ExecuteRequest) MarshalToVT 

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

func (*ExecuteRequest) MarshalVT 

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

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) SizeVT 

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

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

func (*ExecuteRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ExecuteRequest from JSON.

func (*ExecuteRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ExecuteRequest message from JSON.

func (*ExecuteRequest) UnmarshalVT 

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

type ExecuteStatus 

type ExecuteStatus struct {

	// ExecutionState is the current state of the process.
	State ExecutionState `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	// Error is the error message if state is ERROR.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Timestamp is the time of this status update.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

ExecuteStatus is a status update from a running process.

func (*ExecuteStatus) CloneMessageVT 

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

func (*ExecuteStatus) CloneVT 

func (m *ExecuteStatus) CloneVT() *ExecuteStatus

func (*ExecuteStatus) EqualMessageVT 

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

func (*ExecuteStatus) EqualVT 

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

func (*ExecuteStatus) GetError 

func (x *ExecuteStatus) GetError() string

func (*ExecuteStatus) GetState 

func (x *ExecuteStatus) GetState() ExecutionState

func (*ExecuteStatus) GetTimestamp 

func (x *ExecuteStatus) GetTimestamp() *timestamppb.Timestamp

func (*ExecuteStatus) MarshalJSON 

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

MarshalJSON marshals the ExecuteStatus to JSON.

func (*ExecuteStatus) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ExecuteStatus message to JSON.

func (*ExecuteStatus) MarshalProtoText 

func (x *ExecuteStatus) MarshalProtoText() string

func (*ExecuteStatus) MarshalToSizedBufferVT 

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

func (*ExecuteStatus) MarshalToVT 

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

func (*ExecuteStatus) MarshalVT 

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

func (*ExecuteStatus) ProtoMessage 

func (*ExecuteStatus) ProtoMessage()

func (*ExecuteStatus) Reset 

func (x *ExecuteStatus) Reset()

func (*ExecuteStatus) SizeVT 

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

func (*ExecuteStatus) String 

func (x *ExecuteStatus) String() string

func (*ExecuteStatus) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ExecuteStatus from JSON.

func (*ExecuteStatus) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ExecuteStatus message from JSON.

func (*ExecuteStatus) UnmarshalVT 

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

type ExecutionState 

type ExecutionState int32

ExecutionState is the state of a persistent process. 

const (
	// ExecutionState_STARTING is the initial state before the process is ready.
	ExecutionState_ExecutionState_STARTING ExecutionState = 0
	// ExecutionState_RUNNING is the state when the process is running normally.
	ExecutionState_ExecutionState_RUNNING ExecutionState = 1
	// ExecutionState_STOPPING is the state when the process is shutting down.
	ExecutionState_ExecutionState_STOPPING ExecutionState = 2
	// ExecutionState_STOPPED is the state after the process has exited cleanly.
	ExecutionState_ExecutionState_STOPPED ExecutionState = 3
	// ExecutionState_ERROR is the state when the process has exited with an error.
	ExecutionState_ExecutionState_ERROR ExecutionState = 4
)

func (ExecutionState) Enum 

func (x ExecutionState) Enum() *ExecutionState

func (ExecutionState) MarshalJSON 

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

MarshalJSON marshals the ExecutionState to JSON.

func (ExecutionState) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ExecutionState to JSON.

func (ExecutionState) MarshalProtoText 

func (x ExecutionState) MarshalProtoText() string

func (ExecutionState) MarshalText 

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

MarshalText marshals the ExecutionState to text.

func (ExecutionState) String 

func (x ExecutionState) String() string

func (*ExecutionState) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ExecutionState from JSON.

func (*ExecutionState) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ExecutionState from JSON.

func (*ExecutionState) UnmarshalText 

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

UnmarshalText unmarshals the ExecutionState from text.

type ProcessBinding 

type ProcessBinding struct {

	// State is the approval state of this binding.
	State ProcessBindingState `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	// ObjectKey is the world object key this binding is for.
	ObjectKey string `protobuf:"bytes,2,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// TypeId is the ObjectType type ID.
	TypeId string `protobuf:"bytes,3,opt,name=type_id,json=typeId,proto3" json:"typeId,omitempty"`
	// DecidedAt is the time the binding state was last changed.
	DecidedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=decided_at,json=decidedAt,proto3" json:"decidedAt,omitempty"`
	// contains filtered or unexported fields
}

ProcessBinding represents an approved or unapproved process binding for an ObjectType in a Space. Stored in the platform-account ObjectStore.

func (*ProcessBinding) CloneMessageVT 

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

func (*ProcessBinding) CloneVT 

func (m *ProcessBinding) CloneVT() *ProcessBinding

func (*ProcessBinding) EqualMessageVT 

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

func (*ProcessBinding) EqualVT 

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

func (*ProcessBinding) GetDecidedAt 

func (x *ProcessBinding) GetDecidedAt() *timestamppb.Timestamp

func (*ProcessBinding) GetObjectKey 

func (x *ProcessBinding) GetObjectKey() string

func (*ProcessBinding) GetState 

func (x *ProcessBinding) GetState() ProcessBindingState

func (*ProcessBinding) GetTypeId 

func (x *ProcessBinding) GetTypeId() string

func (*ProcessBinding) MarshalJSON 

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

MarshalJSON marshals the ProcessBinding to JSON.

func (*ProcessBinding) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ProcessBinding message to JSON.

func (*ProcessBinding) MarshalProtoText 

func (x *ProcessBinding) MarshalProtoText() string

func (*ProcessBinding) MarshalToSizedBufferVT 

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

func (*ProcessBinding) MarshalToVT 

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

func (*ProcessBinding) MarshalVT 

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

func (*ProcessBinding) ProtoMessage 

func (*ProcessBinding) ProtoMessage()

func (*ProcessBinding) Reset 

func (x *ProcessBinding) Reset()

func (*ProcessBinding) SizeVT 

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

func (*ProcessBinding) String 

func (x *ProcessBinding) String() string

func (*ProcessBinding) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ProcessBinding from JSON.

func (*ProcessBinding) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ProcessBinding message from JSON.

func (*ProcessBinding) UnmarshalVT 

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

type ProcessBindingState 

type ProcessBindingState int32

ProcessBindingState is the approval state of a process binding. 

const (
	// ProcessBindingState_UNAPPROVED means the process is not approved to run.
	ProcessBindingState_ProcessBindingState_UNAPPROVED ProcessBindingState = 0
	// ProcessBindingState_APPROVED means the process is approved to run.
	ProcessBindingState_ProcessBindingState_APPROVED ProcessBindingState = 1
)

func (ProcessBindingState) Enum 

func (x ProcessBindingState) Enum() *ProcessBindingState

func (ProcessBindingState) MarshalJSON 

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

MarshalJSON marshals the ProcessBindingState to JSON.

func (ProcessBindingState) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ProcessBindingState to JSON.

func (ProcessBindingState) MarshalProtoText 

func (x ProcessBindingState) MarshalProtoText() string

func (ProcessBindingState) MarshalText 

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

MarshalText marshals the ProcessBindingState to text.

func (ProcessBindingState) String 

func (x ProcessBindingState) String() string

func (*ProcessBindingState) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ProcessBindingState from JSON.

func (*ProcessBindingState) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ProcessBindingState from JSON.

func (*ProcessBindingState) UnmarshalText 

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

UnmarshalText unmarshals the ProcessBindingState from text.

type SRPCPersistentExecutionServiceClient 

type SRPCPersistentExecutionServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	Execute(ctx context.Context, in *ExecuteRequest) (SRPCPersistentExecutionService_ExecuteClient, error)
}

func NewSRPCPersistentExecutionServiceClient 

func NewSRPCPersistentExecutionServiceClient(cc srpc.Client) SRPCPersistentExecutionServiceClient

func NewSRPCPersistentExecutionServiceClientWithServiceID 

func NewSRPCPersistentExecutionServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPersistentExecutionServiceClient

type SRPCPersistentExecutionServiceHandler 

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

func (SRPCPersistentExecutionServiceHandler) GetMethodIDs 

func (SRPCPersistentExecutionServiceHandler) GetMethodIDs() []string

func (*SRPCPersistentExecutionServiceHandler) GetServiceID 

func (d *SRPCPersistentExecutionServiceHandler) GetServiceID() string

func (*SRPCPersistentExecutionServiceHandler) InvokeMethod 

func (d *SRPCPersistentExecutionServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCPersistentExecutionServiceHandler) InvokeMethod_Execute 

func (SRPCPersistentExecutionServiceHandler) InvokeMethod_Execute(impl SRPCPersistentExecutionServiceServer, strm srpc.Stream) error

type SRPCPersistentExecutionServiceServer 

type SRPCPersistentExecutionServiceServer interface {
	Execute(*ExecuteRequest, SRPCPersistentExecutionService_ExecuteStream) error
}

type SRPCPersistentExecutionService_ExecuteClient 

type SRPCPersistentExecutionService_ExecuteClient interface {
	srpc.Stream
	Recv() (*ExecuteStatus, error)
	RecvTo(*ExecuteStatus) error
}

type SRPCPersistentExecutionService_ExecuteStream 

type SRPCPersistentExecutionService_ExecuteStream interface {
	srpc.Stream
	Send(*ExecuteStatus) error
	SendAndClose(*ExecuteStatus) error
}

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.