internalpb

package
v3.9.6 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NatsMessageType_name = map[int32]string{
		0: "NATS_MESSAGE_TYPE_REGISTER",
		1: "NATS_MESSAGE_TYPE_DEREGISTER",
		2: "NATS_MESSAGE_TYPE_REQUEST",
		3: "NATS_MESSAGE_TYPE_RESPONSE",
	}
	NatsMessageType_value = map[string]int32{
		"NATS_MESSAGE_TYPE_REGISTER":   0,
		"NATS_MESSAGE_TYPE_DEREGISTER": 1,
		"NATS_MESSAGE_TYPE_REQUEST":    2,
		"NATS_MESSAGE_TYPE_RESPONSE":   3,
	}
)

Enum value maps for NatsMessageType.

View Source 
var (
	Strategy_name = map[int32]string{
		0: "STRATEGY_ONE_FOR_ONE",
		1: "STRATEGY_ONE_FOR_ALL",
	}
	Strategy_value = map[string]int32{
		"STRATEGY_ONE_FOR_ONE": 0,
		"STRATEGY_ONE_FOR_ALL": 1,
	}
)

Enum value maps for Strategy.

View Source 
var File_internal_actor_proto protoreflect.FileDescriptor
View Source 
var File_internal_cluster_proto protoreflect.FileDescriptor
View Source 
var File_internal_deadletter_proto protoreflect.FileDescriptor
View Source 
var File_internal_dependency_proto protoreflect.FileDescriptor
View Source 
var File_internal_grain_proto protoreflect.FileDescriptor
View Source 
var File_internal_healthcheck_proto protoreflect.FileDescriptor
View Source 
var File_internal_nats_proto protoreflect.FileDescriptor
View Source 
var File_internal_passivation_proto protoreflect.FileDescriptor
View Source 
var File_internal_peers_proto protoreflect.FileDescriptor
View Source 
var File_internal_remoting_proto protoreflect.FileDescriptor
View Source 
var File_internal_supervision_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Actor added in v3.4.3 

type Actor struct {

	// Specifies the actor address
	Address *goaktpb.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the actor type
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Specifies if the actor is a singleton
	IsSingleton bool `protobuf:"varint,3,opt,name=is_singleton,json=isSingleton,proto3" json:"is_singleton,omitempty"`
	// Specifies if the actor is disabled for relocation
	Relocatable bool `protobuf:"varint,4,opt,name=relocatable,proto3" json:"relocatable,omitempty"`
	// Specifies the passivation strategy
	PassivationStrategy *PassivationStrategy `protobuf:"bytes,5,opt,name=passivation_strategy,json=passivationStrategy,proto3" json:"passivation_strategy,omitempty"`
	// Specifies the dependencies
	Dependencies []*Dependency `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// States whether the actor will require a stash buffer
	EnableStash bool `protobuf:"varint,7,opt,name=enable_stash,json=enableStash,proto3" json:"enable_stash,omitempty"`
	// Specifies the role the actor belongs to
	Role *string `protobuf:"bytes,8,opt,name=role,proto3,oneof" json:"role,omitempty"`
	// contains filtered or unexported fields
}

Actor represents the actor information on the wire.

func (*Actor) Descriptor deprecated added in v3.4.3 

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

Deprecated: Use Actor.ProtoReflect.Descriptor instead.

func (*Actor) GetAddress added in v3.4.3 

func (x *Actor) GetAddress() *goaktpb.Address

func (*Actor) GetDependencies added in v3.4.3 

func (x *Actor) GetDependencies() []*Dependency

func (*Actor) GetEnableStash added in v3.4.3 

func (x *Actor) GetEnableStash() bool

func (*Actor) GetIsSingleton added in v3.4.3 

func (x *Actor) GetIsSingleton() bool

func (*Actor) GetPassivationStrategy added in v3.6.0 

func (x *Actor) GetPassivationStrategy() *PassivationStrategy

func (*Actor) GetRelocatable added in v3.4.3 

func (x *Actor) GetRelocatable() bool

func (*Actor) GetRole added in v3.9.6 

func (x *Actor) GetRole() string

func (*Actor) GetType added in v3.4.3 

func (x *Actor) GetType() string

func (*Actor) ProtoMessage added in v3.4.3 

func (*Actor) ProtoMessage()

func (*Actor) ProtoReflect added in v3.4.3 

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

func (*Actor) Reset added in v3.4.3 

func (x *Actor) Reset()

func (*Actor) String added in v3.4.3 

func (x *Actor) String() string

type DeadlettersCountRequest added in v3.9.5 

type DeadlettersCountRequest struct {

	// Optional: actor ID to filter deadletters for a specific actor.
	ActorId *string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3,oneof" json:"actor_id,omitempty"`
	// contains filtered or unexported fields
}

DeadlettersCountRequest requests the count of deadletters. Optionally, the actor_id can be provided to filter deadletters for a specific actor.

func (*DeadlettersCountRequest) Descriptor deprecated added in v3.9.5 

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

Deprecated: Use DeadlettersCountRequest.ProtoReflect.Descriptor instead.

func (*DeadlettersCountRequest) GetActorId added in v3.9.5 

func (x *DeadlettersCountRequest) GetActorId() string

func (*DeadlettersCountRequest) ProtoMessage added in v3.9.5 

func (*DeadlettersCountRequest) ProtoMessage()

func (*DeadlettersCountRequest) ProtoReflect added in v3.9.5 

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

func (*DeadlettersCountRequest) Reset added in v3.9.5 

func (x *DeadlettersCountRequest) Reset()

func (*DeadlettersCountRequest) String added in v3.9.5 

func (x *DeadlettersCountRequest) String() string

type DeadlettersCountResponse added in v3.9.5 

type DeadlettersCountResponse struct {

	// Specifies the total count of deadletters.
	TotalCount int64 `protobuf:"varint,1,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

DeadlettersCountResponse returns the total number of deadletters. The total_count field contains the count of deadletters found.

func (*DeadlettersCountResponse) Descriptor deprecated added in v3.9.5 

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

Deprecated: Use DeadlettersCountResponse.ProtoReflect.Descriptor instead.

func (*DeadlettersCountResponse) GetTotalCount added in v3.9.5 

func (x *DeadlettersCountResponse) GetTotalCount() int64

func (*DeadlettersCountResponse) ProtoMessage added in v3.9.5 

func (*DeadlettersCountResponse) ProtoMessage()

func (*DeadlettersCountResponse) ProtoReflect added in v3.9.5 

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

func (*DeadlettersCountResponse) Reset added in v3.9.5 

func (x *DeadlettersCountResponse) Reset()

func (*DeadlettersCountResponse) String added in v3.9.5 

func (x *DeadlettersCountResponse) String() string

type DeletePeerState added in v3.9.4 

type DeletePeerState struct {

	// Specifies the peer address
	PeerAddress string `protobuf:"bytes,1,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePeerState) Descriptor deprecated added in v3.9.4 

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

Deprecated: Use DeletePeerState.ProtoReflect.Descriptor instead.

func (*DeletePeerState) GetPeerAddress added in v3.9.4 

func (x *DeletePeerState) GetPeerAddress() string

func (*DeletePeerState) ProtoMessage added in v3.9.4 

func (*DeletePeerState) ProtoMessage()

func (*DeletePeerState) ProtoReflect added in v3.9.4 

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

func (*DeletePeerState) Reset added in v3.9.4 

func (x *DeletePeerState) Reset()

func (*DeletePeerState) String added in v3.9.4 

func (x *DeletePeerState) String() string

type Dependency added in v3.4.0 

type Dependency struct {

	// Specifies the dependency ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Specifies the dependency type name
	TypeName string `protobuf:"bytes,2,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	// The serialized binary data representing the Dependency's value.
	Bytea []byte `protobuf:"bytes,3,opt,name=bytea,proto3" json:"bytea,omitempty"`
	// contains filtered or unexported fields
}

Dependency represents a single actor dependency definition.

This message is used to capture all the necessary metadata and initialization details required to recreate a dependency instance during the actor's lifecycle.

func (*Dependency) Descriptor deprecated added in v3.4.0 

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

Deprecated: Use Dependency.ProtoReflect.Descriptor instead.

func (*Dependency) GetBytea added in v3.4.0 

func (x *Dependency) GetBytea() []byte

func (*Dependency) GetId added in v3.4.0 

func (x *Dependency) GetId() string

func (*Dependency) GetTypeName added in v3.4.0 

func (x *Dependency) GetTypeName() string

func (*Dependency) ProtoMessage added in v3.4.0 

func (*Dependency) ProtoMessage()

func (*Dependency) ProtoReflect added in v3.4.0 

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

func (*Dependency) Reset added in v3.4.0 

func (x *Dependency) Reset()

func (*Dependency) String added in v3.4.0 

func (x *Dependency) String() string

type EscalateDirective 

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

EscalateDirective defines the supervisor escalation directive It escalates the failure to the next parent in the hierarchy, thereby failing itself

func (*EscalateDirective) Descriptor deprecated 

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

Deprecated: Use EscalateDirective.ProtoReflect.Descriptor instead.

func (*EscalateDirective) ProtoMessage 

func (*EscalateDirective) ProtoMessage()

func (*EscalateDirective) ProtoReflect 

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

func (*EscalateDirective) Reset 

func (x *EscalateDirective) Reset()

func (*EscalateDirective) String 

func (x *EscalateDirective) String() string

type GetKindsRequest 

type GetKindsRequest struct {

	// Specifies the node address
	NodeAddress string `protobuf:"bytes,1,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKindsRequest) Descriptor deprecated 

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

Deprecated: Use GetKindsRequest.ProtoReflect.Descriptor instead.

func (*GetKindsRequest) GetNodeAddress 

func (x *GetKindsRequest) GetNodeAddress() string

func (*GetKindsRequest) ProtoMessage 

func (*GetKindsRequest) ProtoMessage()

func (*GetKindsRequest) ProtoReflect 

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

func (*GetKindsRequest) Reset 

func (x *GetKindsRequest) Reset()

func (*GetKindsRequest) String 

func (x *GetKindsRequest) String() string

type GetKindsResponse 

type GetKindsResponse struct {

	// Specifies the list of kinds
	Kinds []string `protobuf:"bytes,1,rep,name=kinds,proto3" json:"kinds,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKindsResponse) Descriptor deprecated 

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

Deprecated: Use GetKindsResponse.ProtoReflect.Descriptor instead.

func (*GetKindsResponse) GetKinds 

func (x *GetKindsResponse) GetKinds() []string

func (*GetKindsResponse) ProtoMessage 

func (*GetKindsResponse) ProtoMessage()

func (*GetKindsResponse) ProtoReflect 

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

func (*GetKindsResponse) Reset 

func (x *GetKindsResponse) Reset()

func (*GetKindsResponse) String 

func (x *GetKindsResponse) String() string

type GetNodeMetricRequest 

type GetNodeMetricRequest struct {

	// Specifies the node address
	NodeAddress string `protobuf:"bytes,1,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeMetricRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeMetricRequest.ProtoReflect.Descriptor instead.

func (*GetNodeMetricRequest) GetNodeAddress 

func (x *GetNodeMetricRequest) GetNodeAddress() string

func (*GetNodeMetricRequest) ProtoMessage 

func (*GetNodeMetricRequest) ProtoMessage()

func (*GetNodeMetricRequest) ProtoReflect 

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

func (*GetNodeMetricRequest) Reset 

func (x *GetNodeMetricRequest) Reset()

func (*GetNodeMetricRequest) String 

func (x *GetNodeMetricRequest) String() string

type GetNodeMetricResponse 

type GetNodeMetricResponse struct {

	// Specifies the node address
	NodeRemoteAddress string `protobuf:"bytes,1,opt,name=node_remote_address,json=nodeRemoteAddress,proto3" json:"node_remote_address,omitempty"`
	// Specifies the actors count for the given node
	ActorsCount uint64 `protobuf:"varint,2,opt,name=actors_count,json=actorsCount,proto3" json:"actors_count,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeMetricResponse) Descriptor deprecated 

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

Deprecated: Use GetNodeMetricResponse.ProtoReflect.Descriptor instead.

func (*GetNodeMetricResponse) GetActorsCount 

func (x *GetNodeMetricResponse) GetActorsCount() uint64

func (*GetNodeMetricResponse) GetNodeRemoteAddress 

func (x *GetNodeMetricResponse) GetNodeRemoteAddress() string

func (*GetNodeMetricResponse) ProtoMessage 

func (*GetNodeMetricResponse) ProtoMessage()

func (*GetNodeMetricResponse) ProtoReflect 

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

func (*GetNodeMetricResponse) Reset 

func (x *GetNodeMetricResponse) Reset()

func (*GetNodeMetricResponse) String 

func (x *GetNodeMetricResponse) String() string

type GetPeerState added in v3.9.4 

type GetPeerState struct {

	// Specifies the peer address
	PeerAddress string `protobuf:"bytes,1,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPeerState) Descriptor deprecated added in v3.9.4 

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

Deprecated: Use GetPeerState.ProtoReflect.Descriptor instead.

func (*GetPeerState) GetPeerAddress added in v3.9.4 

func (x *GetPeerState) GetPeerAddress() string

func (*GetPeerState) ProtoMessage added in v3.9.4 

func (*GetPeerState) ProtoMessage()

func (*GetPeerState) ProtoReflect added in v3.9.4 

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

func (*GetPeerState) Reset added in v3.9.4 

func (x *GetPeerState) Reset()

func (*GetPeerState) String added in v3.9.4 

func (x *GetPeerState) String() string

type Grain added in v3.7.0 

type Grain struct {
	GrainId           *GrainId             `protobuf:"bytes,1,opt,name=grain_id,json=grainId,proto3" json:"grain_id,omitempty"`
	Host              string               `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port              int32                `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Dependencies      []*Dependency        `protobuf:"bytes,4,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	ActivationTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=activation_timeout,json=activationTimeout,proto3" json:"activation_timeout,omitempty"`
	ActivationRetries int32                `protobuf:"varint,6,opt,name=activation_retries,json=activationRetries,proto3" json:"activation_retries,omitempty"`
	// contains filtered or unexported fields
}

Grain represents the virtual actor information on the wire.

func (*Grain) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use Grain.ProtoReflect.Descriptor instead.

func (*Grain) GetActivationRetries added in v3.7.0 

func (x *Grain) GetActivationRetries() int32

func (*Grain) GetActivationTimeout added in v3.7.0 

func (x *Grain) GetActivationTimeout() *durationpb.Duration

func (*Grain) GetDependencies added in v3.7.0 

func (x *Grain) GetDependencies() []*Dependency

func (*Grain) GetGrainId added in v3.7.0 

func (x *Grain) GetGrainId() *GrainId

func (*Grain) GetHost added in v3.7.0 

func (x *Grain) GetHost() string

func (*Grain) GetPort added in v3.7.0 

func (x *Grain) GetPort() int32

func (*Grain) ProtoMessage added in v3.7.0 

func (*Grain) ProtoMessage()

func (*Grain) ProtoReflect added in v3.7.0 

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

func (*Grain) Reset added in v3.7.0 

func (x *Grain) Reset()

func (*Grain) String added in v3.7.0 

func (x *Grain) String() string

type GrainId added in v3.7.0 

type GrainId struct {
	Kind  string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GrainId) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use GrainId.ProtoReflect.Descriptor instead.

func (*GrainId) GetKind added in v3.7.0 

func (x *GrainId) GetKind() string

func (*GrainId) GetName added in v3.7.0 

func (x *GrainId) GetName() string

func (*GrainId) GetValue added in v3.7.0 

func (x *GrainId) GetValue() string

func (*GrainId) ProtoMessage added in v3.7.0 

func (*GrainId) ProtoMessage()

func (*GrainId) ProtoReflect added in v3.7.0 

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

func (*GrainId) Reset added in v3.7.0 

func (x *GrainId) Reset()

func (*GrainId) String added in v3.7.0 

func (x *GrainId) String() string

type HealthCheckRequest added in v3.9.3 

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

HealthCheckRequest Sent internally to an actor (or actor system component) to verify that:

  1. The mailbox is responsive.
  2. The actor has completed its initialization.
  3. The actor can accept user messages.

Empty by design: presence of a valid response implies readiness.

func (*HealthCheckRequest) Descriptor deprecated added in v3.9.3 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) ProtoMessage added in v3.9.3 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect added in v3.9.3 

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

func (*HealthCheckRequest) Reset added in v3.9.3 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String added in v3.9.3 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse added in v3.9.3 

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

HealthCheckResponse Returned when an actor (or component) is ready/healthy. If a timeout or failure occurs upstream, the absence of this response is interpreted as not-ready/unhealthy. Extend ONLY if there is a strong need to surface diagnostic details.

func (*HealthCheckResponse) Descriptor deprecated added in v3.9.3 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) ProtoMessage added in v3.9.3 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect added in v3.9.3 

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

func (*HealthCheckResponse) Reset added in v3.9.3 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String added in v3.9.3 

func (x *HealthCheckResponse) String() string

type LongLivedPassivation added in v3.6.0 

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

LongLivedPassivation represents a strategy where the actor is long-lived and should never be passivated automatically.

This is suitable for actors that are critical system components or serve high-throughput workloads with consistent usage patterns.

func (*LongLivedPassivation) Descriptor deprecated added in v3.6.0 

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

Deprecated: Use LongLivedPassivation.ProtoReflect.Descriptor instead.

func (*LongLivedPassivation) ProtoMessage added in v3.6.0 

func (*LongLivedPassivation) ProtoMessage()

func (*LongLivedPassivation) ProtoReflect added in v3.6.0 

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

func (*LongLivedPassivation) Reset added in v3.6.0 

func (x *LongLivedPassivation) Reset()

func (*LongLivedPassivation) String added in v3.6.0 

func (x *LongLivedPassivation) String() string

type MessagesCountBasedPassivation added in v3.6.0 

type MessagesCountBasedPassivation struct {
	MaxMessages int64 `protobuf:"varint,1,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

MessagesCountBasedPassivation defines a strategy where an actor is passivated after processing a certain number of messages, regardless of time.

max_messages: 

The maximum number of messages an actor is allowed to process
before it is considered for passivation. This can be useful in cases
where actors have expensive memory or lifecycle costs.

func (*MessagesCountBasedPassivation) Descriptor deprecated added in v3.6.0 

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

Deprecated: Use MessagesCountBasedPassivation.ProtoReflect.Descriptor instead.

func (*MessagesCountBasedPassivation) GetMaxMessages added in v3.6.0 

func (x *MessagesCountBasedPassivation) GetMaxMessages() int64

func (*MessagesCountBasedPassivation) ProtoMessage added in v3.6.0 

func (*MessagesCountBasedPassivation) ProtoMessage()

func (*MessagesCountBasedPassivation) ProtoReflect added in v3.6.0 

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

func (*MessagesCountBasedPassivation) Reset added in v3.6.0 

func (x *MessagesCountBasedPassivation) Reset()

func (*MessagesCountBasedPassivation) String added in v3.6.0 

func (x *MessagesCountBasedPassivation) String() string

type NatsMessage 

type NatsMessage struct {

	// Specifies the host name of the client node
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the port of the client node
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Specifies the client name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Specifies the message type
	MessageType NatsMessageType `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

NatsMessage defines the NATs message used by the discovery provider

func (*NatsMessage) Descriptor deprecated 

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

Deprecated: Use NatsMessage.ProtoReflect.Descriptor instead.

func (*NatsMessage) GetHost 

func (x *NatsMessage) GetHost() string

func (*NatsMessage) GetMessageType 

func (x *NatsMessage) GetMessageType() NatsMessageType

func (*NatsMessage) GetName 

func (x *NatsMessage) GetName() string

func (*NatsMessage) GetPort 

func (x *NatsMessage) GetPort() int32

func (*NatsMessage) ProtoMessage 

func (*NatsMessage) ProtoMessage()

func (*NatsMessage) ProtoReflect 

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

func (*NatsMessage) Reset 

func (x *NatsMessage) Reset()

func (*NatsMessage) String 

func (x *NatsMessage) String() string

type NatsMessageType 

type NatsMessageType int32

NatsMessageType defines the NATs message type 

const (
	NatsMessageType_NATS_MESSAGE_TYPE_REGISTER   NatsMessageType = 0
	NatsMessageType_NATS_MESSAGE_TYPE_DEREGISTER NatsMessageType = 1
	NatsMessageType_NATS_MESSAGE_TYPE_REQUEST    NatsMessageType = 2
	NatsMessageType_NATS_MESSAGE_TYPE_RESPONSE   NatsMessageType = 3
)

func (NatsMessageType) Descriptor 

func (NatsMessageType) Descriptor() protoreflect.EnumDescriptor

func (NatsMessageType) Enum 

func (x NatsMessageType) Enum() *NatsMessageType

func (NatsMessageType) EnumDescriptor deprecated 

func (NatsMessageType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NatsMessageType.Descriptor instead.

func (NatsMessageType) Number 

func (x NatsMessageType) Number() protoreflect.EnumNumber

func (NatsMessageType) String 

func (x NatsMessageType) String() string

func (NatsMessageType) Type 

func (NatsMessageType) Type() protoreflect.EnumType

type Panicking added in v3.9.3 

type Panicking struct {

	// Specifies the actor id
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// Specifies the error message
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Specifies the directive
	//
	// Types that are valid to be assigned to Directive:
	//
	//	*Panicking_Stop
	//	*Panicking_Resume
	//	*Panicking_Restart
	//	*Panicking_Escalate
	Directive isPanicking_Directive `protobuf_oneof:"directive"`
	// Specifies the strategy
	Strategy Strategy `protobuf:"varint,7,opt,name=strategy,proto3,enum=internalpb.Strategy" json:"strategy,omitempty"`
	// Specifies the message that triggered the failure
	Message *anypb.Any `protobuf:"bytes,8,opt,name=message,proto3" json:"message,omitempty"`
	// Specifies when the error occurred
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Panicking message is sent by a child actor to its parent when it is panicking or returning an error while processing messages

func (*Panicking) Descriptor deprecated added in v3.9.3 

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

Deprecated: Use Panicking.ProtoReflect.Descriptor instead.

func (*Panicking) GetActorId added in v3.9.3 

func (x *Panicking) GetActorId() string

func (*Panicking) GetDirective added in v3.9.3 

func (x *Panicking) GetDirective() isPanicking_Directive

func (*Panicking) GetErrorMessage added in v3.9.3 

func (x *Panicking) GetErrorMessage() string

func (*Panicking) GetEscalate added in v3.9.3 

func (x *Panicking) GetEscalate() *EscalateDirective

func (*Panicking) GetMessage added in v3.9.3 

func (x *Panicking) GetMessage() *anypb.Any

func (*Panicking) GetRestart added in v3.9.3 

func (x *Panicking) GetRestart() *RestartDirective

func (*Panicking) GetResume added in v3.9.3 

func (x *Panicking) GetResume() *ResumeDirective

func (*Panicking) GetStop added in v3.9.3 

func (x *Panicking) GetStop() *StopDirective

func (*Panicking) GetStrategy added in v3.9.3 

func (x *Panicking) GetStrategy() Strategy

func (*Panicking) GetTimestamp added in v3.9.3 

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

func (*Panicking) ProtoMessage added in v3.9.3 

func (*Panicking) ProtoMessage()

func (*Panicking) ProtoReflect added in v3.9.3 

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

func (*Panicking) Reset added in v3.9.3 

func (x *Panicking) Reset()

func (*Panicking) String added in v3.9.3 

func (x *Panicking) String() string

type Panicking_Escalate added in v3.9.3 

type Panicking_Escalate struct {
	Escalate *EscalateDirective `protobuf:"bytes,6,opt,name=escalate,proto3,oneof"`
}

type Panicking_Restart added in v3.9.3 

type Panicking_Restart struct {
	Restart *RestartDirective `protobuf:"bytes,5,opt,name=restart,proto3,oneof"`
}

type Panicking_Resume added in v3.9.3 

type Panicking_Resume struct {
	Resume *ResumeDirective `protobuf:"bytes,4,opt,name=resume,proto3,oneof"`
}

type Panicking_Stop added in v3.9.3 

type Panicking_Stop struct {
	Stop *StopDirective `protobuf:"bytes,3,opt,name=stop,proto3,oneof"`
}

type PassivationStrategy added in v3.6.0 

type PassivationStrategy struct {

	// Types that are valid to be assigned to Strategy:
	//
	//	*PassivationStrategy_TimeBased
	//	*PassivationStrategy_MessagesCountBased
	//	*PassivationStrategy_LongLived
	Strategy isPassivationStrategy_Strategy `protobuf_oneof:"strategy"`
	// contains filtered or unexported fields
}

PassivationStrategy encapsulates all supported passivation strategies for actors. Exactly one of the strategies should be specified.

strategy:

  • time_based: Uses time-based idle detection to trigger passivation.
  • messages_count_based: Uses message count threshold to trigger passivation.
  • long_lived: Disables automatic passivation entirely.

func (*PassivationStrategy) Descriptor deprecated added in v3.6.0 

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

Deprecated: Use PassivationStrategy.ProtoReflect.Descriptor instead.

func (*PassivationStrategy) GetLongLived added in v3.6.0 

func (x *PassivationStrategy) GetLongLived() *LongLivedPassivation

func (*PassivationStrategy) GetMessagesCountBased added in v3.6.0 

func (x *PassivationStrategy) GetMessagesCountBased() *MessagesCountBasedPassivation

func (*PassivationStrategy) GetStrategy added in v3.6.0 

func (x *PassivationStrategy) GetStrategy() isPassivationStrategy_Strategy

func (*PassivationStrategy) GetTimeBased added in v3.6.0 

func (x *PassivationStrategy) GetTimeBased() *TimeBasedPassivation

func (*PassivationStrategy) ProtoMessage added in v3.6.0 

func (*PassivationStrategy) ProtoMessage()

func (*PassivationStrategy) ProtoReflect added in v3.6.0 

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

func (*PassivationStrategy) Reset added in v3.6.0 

func (x *PassivationStrategy) Reset()

func (*PassivationStrategy) String added in v3.6.0 

func (x *PassivationStrategy) String() string

type PassivationStrategy_LongLived added in v3.6.0 

type PassivationStrategy_LongLived struct {
	LongLived *LongLivedPassivation `protobuf:"bytes,3,opt,name=long_lived,json=longLived,proto3,oneof"`
}

type PassivationStrategy_MessagesCountBased added in v3.6.0 

type PassivationStrategy_MessagesCountBased struct {
	MessagesCountBased *MessagesCountBasedPassivation `protobuf:"bytes,2,opt,name=messages_count_based,json=messagesCountBased,proto3,oneof"`
}

type PassivationStrategy_TimeBased added in v3.6.0 

type PassivationStrategy_TimeBased struct {
	TimeBased *TimeBasedPassivation `protobuf:"bytes,1,opt,name=time_based,json=timeBased,proto3,oneof"`
}

type PeerState 

type PeerState struct {

	// Specifies the peer host
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remoting port
	RemotingPort int32 `protobuf:"varint,2,opt,name=remoting_port,json=remotingPort,proto3" json:"remoting_port,omitempty"`
	// Specifies the remoting host
	PeersPort int32 `protobuf:"varint,3,opt,name=peers_port,json=peersPort,proto3" json:"peers_port,omitempty"`
	// Specifies the list of actors
	// actorName -> Actor
	Actors map[string]*Actor `` /* 139-byte string literal not displayed */
	// grainId -> Grain
	Grains map[string]*Grain `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PeerState) Descriptor deprecated 

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

Deprecated: Use PeerState.ProtoReflect.Descriptor instead.

func (*PeerState) GetActors 

func (x *PeerState) GetActors() map[string]*Actor

func (*PeerState) GetGrains added in v3.7.0 

func (x *PeerState) GetGrains() map[string]*Grain

func (*PeerState) GetHost 

func (x *PeerState) GetHost() string

func (*PeerState) GetPeersPort 

func (x *PeerState) GetPeersPort() int32

func (*PeerState) GetRemotingPort 

func (x *PeerState) GetRemotingPort() int32

func (*PeerState) ProtoMessage 

func (*PeerState) ProtoMessage()

func (*PeerState) ProtoReflect 

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

func (*PeerState) Reset 

func (x *PeerState) Reset()

func (*PeerState) String 

func (x *PeerState) String() string

type PersistPeerActor added in v3.9.4 

type PersistPeerActor struct {

	// Specifies the peer host
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remoting port
	RemotingPort int32 `protobuf:"varint,2,opt,name=remoting_port,json=remotingPort,proto3" json:"remoting_port,omitempty"`
	// Specifies the remoting host
	PeersPort int32 `protobuf:"varint,3,opt,name=peers_port,json=peersPort,proto3" json:"peers_port,omitempty"`
	// Specifies the actor
	Actor *Actor `protobuf:"bytes,4,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

func (*PersistPeerActor) Descriptor deprecated added in v3.9.4 

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

Deprecated: Use PersistPeerActor.ProtoReflect.Descriptor instead.

func (*PersistPeerActor) GetActor added in v3.9.4 

func (x *PersistPeerActor) GetActor() *Actor

func (*PersistPeerActor) GetHost added in v3.9.4 

func (x *PersistPeerActor) GetHost() string

func (*PersistPeerActor) GetPeersPort added in v3.9.4 

func (x *PersistPeerActor) GetPeersPort() int32

func (*PersistPeerActor) GetRemotingPort added in v3.9.4 

func (x *PersistPeerActor) GetRemotingPort() int32

func (*PersistPeerActor) ProtoMessage added in v3.9.4 

func (*PersistPeerActor) ProtoMessage()

func (*PersistPeerActor) ProtoReflect added in v3.9.4 

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

func (*PersistPeerActor) Reset added in v3.9.4 

func (x *PersistPeerActor) Reset()

func (*PersistPeerActor) String added in v3.9.4 

func (x *PersistPeerActor) String() string

type PersistPeerGrain added in v3.9.4 

type PersistPeerGrain struct {

	// Specifies the peer host
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remoting port
	RemotingPort int32 `protobuf:"varint,2,opt,name=remoting_port,json=remotingPort,proto3" json:"remoting_port,omitempty"`
	// Specifies the remoting host
	PeersPort int32 `protobuf:"varint,3,opt,name=peers_port,json=peersPort,proto3" json:"peers_port,omitempty"`
	// Specifies the grain
	Grain *Grain `protobuf:"bytes,4,opt,name=grain,proto3" json:"grain,omitempty"`
	// contains filtered or unexported fields
}

func (*PersistPeerGrain) Descriptor deprecated added in v3.9.4 

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

Deprecated: Use PersistPeerGrain.ProtoReflect.Descriptor instead.

func (*PersistPeerGrain) GetGrain added in v3.9.4 

func (x *PersistPeerGrain) GetGrain() *Grain

func (*PersistPeerGrain) GetHost added in v3.9.4 

func (x *PersistPeerGrain) GetHost() string

func (*PersistPeerGrain) GetPeersPort added in v3.9.4 

func (x *PersistPeerGrain) GetPeersPort() int32

func (*PersistPeerGrain) GetRemotingPort added in v3.9.4 

func (x *PersistPeerGrain) GetRemotingPort() int32

func (*PersistPeerGrain) ProtoMessage added in v3.9.4 

func (*PersistPeerGrain) ProtoMessage()

func (*PersistPeerGrain) ProtoReflect added in v3.9.4 

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

func (*PersistPeerGrain) Reset added in v3.9.4 

func (x *PersistPeerGrain) Reset()

func (*PersistPeerGrain) String added in v3.9.4 

func (x *PersistPeerGrain) String() string

type PublishDeadletters added in v3.9.5 

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

PublishDeadletters is used to trigger the publishing of all accumulated deadletters. This message does not carry any payload.

func (*PublishDeadletters) Descriptor deprecated added in v3.9.5 

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

Deprecated: Use PublishDeadletters.ProtoReflect.Descriptor instead.

func (*PublishDeadletters) ProtoMessage added in v3.9.5 

func (*PublishDeadletters) ProtoMessage()

func (*PublishDeadletters) ProtoReflect added in v3.9.5 

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

func (*PublishDeadletters) Reset added in v3.9.5 

func (x *PublishDeadletters) Reset()

func (*PublishDeadletters) String added in v3.9.5 

func (x *PublishDeadletters) String() string

type Rebalance 

type Rebalance struct {

	// Specifies the peer state
	PeerState *PeerState `protobuf:"bytes,1,opt,name=peer_state,json=peerState,proto3" json:"peer_state,omitempty"`
	// contains filtered or unexported fields
}

func (*Rebalance) Descriptor deprecated 

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

Deprecated: Use Rebalance.ProtoReflect.Descriptor instead.

func (*Rebalance) GetPeerState 

func (x *Rebalance) GetPeerState() *PeerState

func (*Rebalance) ProtoMessage 

func (*Rebalance) ProtoMessage()

func (*Rebalance) ProtoReflect 

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

func (*Rebalance) Reset 

func (x *Rebalance) Reset()

func (*Rebalance) String 

func (x *Rebalance) String() string

type RebalanceComplete 

type RebalanceComplete struct {

	// Specifies the peer address
	PeerAddress string `protobuf:"bytes,1,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"`
	// contains filtered or unexported fields
}

func (*RebalanceComplete) Descriptor deprecated 

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

Deprecated: Use RebalanceComplete.ProtoReflect.Descriptor instead.

func (*RebalanceComplete) GetPeerAddress 

func (x *RebalanceComplete) GetPeerAddress() string

func (*RebalanceComplete) ProtoMessage 

func (*RebalanceComplete) ProtoMessage()

func (*RebalanceComplete) ProtoReflect 

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

func (*RebalanceComplete) Reset 

func (x *RebalanceComplete) Reset()

func (*RebalanceComplete) String 

func (x *RebalanceComplete) String() string

type RemoteActivateGrainRequest added in v3.7.0 

type RemoteActivateGrainRequest struct {
	Grain *Grain `protobuf:"bytes,1,opt,name=grain,proto3" json:"grain,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteActivateGrainRequest) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use RemoteActivateGrainRequest.ProtoReflect.Descriptor instead.

func (*RemoteActivateGrainRequest) GetGrain added in v3.7.0 

func (x *RemoteActivateGrainRequest) GetGrain() *Grain

func (*RemoteActivateGrainRequest) ProtoMessage added in v3.7.0 

func (*RemoteActivateGrainRequest) ProtoMessage()

func (*RemoteActivateGrainRequest) ProtoReflect added in v3.7.0 

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

func (*RemoteActivateGrainRequest) Reset added in v3.7.0 

func (x *RemoteActivateGrainRequest) Reset()

func (*RemoteActivateGrainRequest) String added in v3.7.0 

func (x *RemoteActivateGrainRequest) String() string

type RemoteActivateGrainResponse added in v3.7.0 

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

func (*RemoteActivateGrainResponse) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use RemoteActivateGrainResponse.ProtoReflect.Descriptor instead.

func (*RemoteActivateGrainResponse) ProtoMessage added in v3.7.0 

func (*RemoteActivateGrainResponse) ProtoMessage()

func (*RemoteActivateGrainResponse) ProtoReflect added in v3.7.0 

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

func (*RemoteActivateGrainResponse) Reset added in v3.7.0 

func (x *RemoteActivateGrainResponse) Reset()

func (*RemoteActivateGrainResponse) String added in v3.7.0 

func (x *RemoteActivateGrainResponse) String() string

type RemoteAskGrainRequest added in v3.7.0 

type RemoteAskGrainRequest struct {
	Grain          *Grain               `protobuf:"bytes,1,opt,name=grain,proto3" json:"grain,omitempty"`
	Message        *anypb.Any           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	RequestTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteAskGrainRequest) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use RemoteAskGrainRequest.ProtoReflect.Descriptor instead.

func (*RemoteAskGrainRequest) GetGrain added in v3.7.0 

func (x *RemoteAskGrainRequest) GetGrain() *Grain

func (*RemoteAskGrainRequest) GetMessage added in v3.7.0 

func (x *RemoteAskGrainRequest) GetMessage() *anypb.Any

func (*RemoteAskGrainRequest) GetRequestTimeout added in v3.7.0 

func (x *RemoteAskGrainRequest) GetRequestTimeout() *durationpb.Duration

func (*RemoteAskGrainRequest) ProtoMessage added in v3.7.0 

func (*RemoteAskGrainRequest) ProtoMessage()

func (*RemoteAskGrainRequest) ProtoReflect added in v3.7.0 

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

func (*RemoteAskGrainRequest) Reset added in v3.7.0 

func (x *RemoteAskGrainRequest) Reset()

func (*RemoteAskGrainRequest) String added in v3.7.0 

func (x *RemoteAskGrainRequest) String() string

type RemoteAskGrainResponse added in v3.7.0 

type RemoteAskGrainResponse struct {
	Message *anypb.Any `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteAskGrainResponse) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use RemoteAskGrainResponse.ProtoReflect.Descriptor instead.

func (*RemoteAskGrainResponse) GetMessage added in v3.7.0 

func (x *RemoteAskGrainResponse) GetMessage() *anypb.Any

func (*RemoteAskGrainResponse) ProtoMessage added in v3.7.0 

func (*RemoteAskGrainResponse) ProtoMessage()

func (*RemoteAskGrainResponse) ProtoReflect added in v3.7.0 

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

func (*RemoteAskGrainResponse) Reset added in v3.7.0 

func (x *RemoteAskGrainResponse) Reset()

func (*RemoteAskGrainResponse) String added in v3.7.0 

func (x *RemoteAskGrainResponse) String() string

type RemoteAskRequest 

type RemoteAskRequest struct {

	// Specifies the remote message to send
	RemoteMessages []*RemoteMessage `protobuf:"bytes,1,rep,name=remote_messages,json=remoteMessages,proto3" json:"remote_messages,omitempty"`
	// Specifies the timeout(how long to wait for a reply)
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

RemoteAsk is used to send a message to an actor remotely and expect a response immediately.

func (*RemoteAskRequest) Descriptor deprecated 

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

Deprecated: Use RemoteAskRequest.ProtoReflect.Descriptor instead.

func (*RemoteAskRequest) GetRemoteMessages added in v3.3.0 

func (x *RemoteAskRequest) GetRemoteMessages() []*RemoteMessage

func (*RemoteAskRequest) GetTimeout 

func (x *RemoteAskRequest) GetTimeout() *durationpb.Duration

func (*RemoteAskRequest) ProtoMessage 

func (*RemoteAskRequest) ProtoMessage()

func (*RemoteAskRequest) ProtoReflect 

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

func (*RemoteAskRequest) Reset 

func (x *RemoteAskRequest) Reset()

func (*RemoteAskRequest) String 

func (x *RemoteAskRequest) String() string

type RemoteAskResponse 

type RemoteAskResponse struct {

	// Specifies the message to send to the actor
	// Any proto message is allowed to be sent
	Messages []*anypb.Any `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteAskResponse) Descriptor deprecated 

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

Deprecated: Use RemoteAskResponse.ProtoReflect.Descriptor instead.

func (*RemoteAskResponse) GetMessages added in v3.3.0 

func (x *RemoteAskResponse) GetMessages() []*anypb.Any

func (*RemoteAskResponse) ProtoMessage 

func (*RemoteAskResponse) ProtoMessage()

func (*RemoteAskResponse) ProtoReflect 

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

func (*RemoteAskResponse) Reset 

func (x *RemoteAskResponse) Reset()

func (*RemoteAskResponse) String 

func (x *RemoteAskResponse) String() string

type RemoteLookupRequest 

type RemoteLookupRequest struct {

	// Specifies the remote host address
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remote port
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Specifies the actor name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

RemoteLookupRequest checks whether a given actor exists on a remote host

func (*RemoteLookupRequest) Descriptor deprecated 

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

Deprecated: Use RemoteLookupRequest.ProtoReflect.Descriptor instead.

func (*RemoteLookupRequest) GetHost 

func (x *RemoteLookupRequest) GetHost() string

func (*RemoteLookupRequest) GetName 

func (x *RemoteLookupRequest) GetName() string

func (*RemoteLookupRequest) GetPort 

func (x *RemoteLookupRequest) GetPort() int32

func (*RemoteLookupRequest) ProtoMessage 

func (*RemoteLookupRequest) ProtoMessage()

func (*RemoteLookupRequest) ProtoReflect 

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

func (*RemoteLookupRequest) Reset 

func (x *RemoteLookupRequest) Reset()

func (*RemoteLookupRequest) String 

func (x *RemoteLookupRequest) String() string

type RemoteLookupResponse 

type RemoteLookupResponse struct {

	// Specifies the actor address
	Address *goaktpb.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteLookupResponse) Descriptor deprecated 

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

Deprecated: Use RemoteLookupResponse.ProtoReflect.Descriptor instead.

func (*RemoteLookupResponse) GetAddress 

func (x *RemoteLookupResponse) GetAddress() *goaktpb.Address

func (*RemoteLookupResponse) ProtoMessage 

func (*RemoteLookupResponse) ProtoMessage()

func (*RemoteLookupResponse) ProtoReflect 

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

func (*RemoteLookupResponse) Reset 

func (x *RemoteLookupResponse) Reset()

func (*RemoteLookupResponse) String 

func (x *RemoteLookupResponse) String() string

type RemoteMessage 

type RemoteMessage struct {

	// Specifies the sender' address
	Sender *goaktpb.Address `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// Specifies the actor address
	Receiver *goaktpb.Address `protobuf:"bytes,2,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Specifies the message to send to the actor
	// Any proto message is allowed to be sent
	Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

RemoteMessage will be used by Actors to communicate remotely

func (*RemoteMessage) Descriptor deprecated 

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

Deprecated: Use RemoteMessage.ProtoReflect.Descriptor instead.

func (*RemoteMessage) GetMessage 

func (x *RemoteMessage) GetMessage() *anypb.Any

func (*RemoteMessage) GetReceiver 

func (x *RemoteMessage) GetReceiver() *goaktpb.Address

func (*RemoteMessage) GetSender 

func (x *RemoteMessage) GetSender() *goaktpb.Address

func (*RemoteMessage) ProtoMessage 

func (*RemoteMessage) ProtoMessage()

func (*RemoteMessage) ProtoReflect 

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

func (*RemoteMessage) Reset 

func (x *RemoteMessage) Reset()

func (*RemoteMessage) String 

func (x *RemoteMessage) String() string

type RemoteReSpawnRequest 

type RemoteReSpawnRequest struct {

	// Specifies the remote host address
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remote port
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Specifies the actor name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteReSpawnRequest) Descriptor deprecated 

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

Deprecated: Use RemoteReSpawnRequest.ProtoReflect.Descriptor instead.

func (*RemoteReSpawnRequest) GetHost 

func (x *RemoteReSpawnRequest) GetHost() string

func (*RemoteReSpawnRequest) GetName 

func (x *RemoteReSpawnRequest) GetName() string

func (*RemoteReSpawnRequest) GetPort 

func (x *RemoteReSpawnRequest) GetPort() int32

func (*RemoteReSpawnRequest) ProtoMessage 

func (*RemoteReSpawnRequest) ProtoMessage()

func (*RemoteReSpawnRequest) ProtoReflect 

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

func (*RemoteReSpawnRequest) Reset 

func (x *RemoteReSpawnRequest) Reset()

func (*RemoteReSpawnRequest) String 

func (x *RemoteReSpawnRequest) String() string

type RemoteReSpawnResponse 

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

func (*RemoteReSpawnResponse) Descriptor deprecated 

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

Deprecated: Use RemoteReSpawnResponse.ProtoReflect.Descriptor instead.

func (*RemoteReSpawnResponse) ProtoMessage 

func (*RemoteReSpawnResponse) ProtoMessage()

func (*RemoteReSpawnResponse) ProtoReflect 

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

func (*RemoteReSpawnResponse) Reset 

func (x *RemoteReSpawnResponse) Reset()

func (*RemoteReSpawnResponse) String 

func (x *RemoteReSpawnResponse) String() string

type RemoteReinstateRequest added in v3.4.4 

type RemoteReinstateRequest struct {

	// Specifies the remote host address
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remote port
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Specifies the actor name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteReinstateRequest) Descriptor deprecated added in v3.4.4 

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

Deprecated: Use RemoteReinstateRequest.ProtoReflect.Descriptor instead.

func (*RemoteReinstateRequest) GetHost added in v3.4.4 

func (x *RemoteReinstateRequest) GetHost() string

func (*RemoteReinstateRequest) GetName added in v3.4.4 

func (x *RemoteReinstateRequest) GetName() string

func (*RemoteReinstateRequest) GetPort added in v3.4.4 

func (x *RemoteReinstateRequest) GetPort() int32

func (*RemoteReinstateRequest) ProtoMessage added in v3.4.4 

func (*RemoteReinstateRequest) ProtoMessage()

func (*RemoteReinstateRequest) ProtoReflect added in v3.4.4 

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

func (*RemoteReinstateRequest) Reset added in v3.4.4 

func (x *RemoteReinstateRequest) Reset()

func (*RemoteReinstateRequest) String added in v3.4.4 

func (x *RemoteReinstateRequest) String() string

type RemoteReinstateResponse added in v3.4.4 

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

func (*RemoteReinstateResponse) Descriptor deprecated added in v3.4.4 

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

Deprecated: Use RemoteReinstateResponse.ProtoReflect.Descriptor instead.

func (*RemoteReinstateResponse) ProtoMessage added in v3.4.4 

func (*RemoteReinstateResponse) ProtoMessage()

func (*RemoteReinstateResponse) ProtoReflect added in v3.4.4 

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

func (*RemoteReinstateResponse) Reset added in v3.4.4 

func (x *RemoteReinstateResponse) Reset()

func (*RemoteReinstateResponse) String added in v3.4.4 

func (x *RemoteReinstateResponse) String() string

type RemoteSpawnRequest 

type RemoteSpawnRequest struct {

	// Specifies the remote host address
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remote port
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Specifies the actor name.
	ActorName string `protobuf:"bytes,3,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	// Specifies the actor type
	ActorType string `protobuf:"bytes,4,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	// Specifies if the actor is a singleton
	IsSingleton bool `protobuf:"varint,5,opt,name=is_singleton,json=isSingleton,proto3" json:"is_singleton,omitempty"`
	// Specifies if the actor is relocatable
	Relocatable bool `protobuf:"varint,6,opt,name=relocatable,proto3" json:"relocatable,omitempty"`
	// Specifies the passivation strategy
	PassivationStrategy *PassivationStrategy `protobuf:"bytes,7,opt,name=passivation_strategy,json=passivationStrategy,proto3" json:"passivation_strategy,omitempty"`
	// Specifies the dependencies
	Dependencies []*Dependency `protobuf:"bytes,8,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// States whether the actor will require a stash buffer
	EnableStash bool `protobuf:"varint,9,opt,name=enable_stash,json=enableStash,proto3" json:"enable_stash,omitempty"`
	// Specifies the role the actor belongs to
	Role *string `protobuf:"bytes,10,opt,name=role,proto3,oneof" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteSpawnRequest) Descriptor deprecated 

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

Deprecated: Use RemoteSpawnRequest.ProtoReflect.Descriptor instead.

func (*RemoteSpawnRequest) GetActorName 

func (x *RemoteSpawnRequest) GetActorName() string

func (*RemoteSpawnRequest) GetActorType 

func (x *RemoteSpawnRequest) GetActorType() string

func (*RemoteSpawnRequest) GetDependencies added in v3.4.0 

func (x *RemoteSpawnRequest) GetDependencies() []*Dependency

func (*RemoteSpawnRequest) GetEnableStash added in v3.4.0 

func (x *RemoteSpawnRequest) GetEnableStash() bool

func (*RemoteSpawnRequest) GetHost 

func (x *RemoteSpawnRequest) GetHost() string

func (*RemoteSpawnRequest) GetIsSingleton added in v3.1.0 

func (x *RemoteSpawnRequest) GetIsSingleton() bool

func (*RemoteSpawnRequest) GetPassivationStrategy added in v3.6.0 

func (x *RemoteSpawnRequest) GetPassivationStrategy() *PassivationStrategy

func (*RemoteSpawnRequest) GetPort 

func (x *RemoteSpawnRequest) GetPort() int32

func (*RemoteSpawnRequest) GetRelocatable added in v3.1.0 

func (x *RemoteSpawnRequest) GetRelocatable() bool

func (*RemoteSpawnRequest) GetRole added in v3.9.6 

func (x *RemoteSpawnRequest) GetRole() string

func (*RemoteSpawnRequest) ProtoMessage 

func (*RemoteSpawnRequest) ProtoMessage()

func (*RemoteSpawnRequest) ProtoReflect 

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

func (*RemoteSpawnRequest) Reset 

func (x *RemoteSpawnRequest) Reset()

func (*RemoteSpawnRequest) String 

func (x *RemoteSpawnRequest) String() string

type RemoteSpawnResponse 

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

func (*RemoteSpawnResponse) Descriptor deprecated 

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

Deprecated: Use RemoteSpawnResponse.ProtoReflect.Descriptor instead.

func (*RemoteSpawnResponse) ProtoMessage 

func (*RemoteSpawnResponse) ProtoMessage()

func (*RemoteSpawnResponse) ProtoReflect 

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

func (*RemoteSpawnResponse) Reset 

func (x *RemoteSpawnResponse) Reset()

func (*RemoteSpawnResponse) String 

func (x *RemoteSpawnResponse) String() string

type RemoteStopRequest 

type RemoteStopRequest struct {

	// Specifies the remote host address
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// Specifies the remote port
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Specifies the actor name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteStopRequest) Descriptor deprecated 

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

Deprecated: Use RemoteStopRequest.ProtoReflect.Descriptor instead.

func (*RemoteStopRequest) GetHost 

func (x *RemoteStopRequest) GetHost() string

func (*RemoteStopRequest) GetName 

func (x *RemoteStopRequest) GetName() string

func (*RemoteStopRequest) GetPort 

func (x *RemoteStopRequest) GetPort() int32

func (*RemoteStopRequest) ProtoMessage 

func (*RemoteStopRequest) ProtoMessage()

func (*RemoteStopRequest) ProtoReflect 

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

func (*RemoteStopRequest) Reset 

func (x *RemoteStopRequest) Reset()

func (*RemoteStopRequest) String 

func (x *RemoteStopRequest) String() string

type RemoteStopResponse 

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

func (*RemoteStopResponse) Descriptor deprecated 

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

Deprecated: Use RemoteStopResponse.ProtoReflect.Descriptor instead.

func (*RemoteStopResponse) ProtoMessage 

func (*RemoteStopResponse) ProtoMessage()

func (*RemoteStopResponse) ProtoReflect 

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

func (*RemoteStopResponse) Reset 

func (x *RemoteStopResponse) Reset()

func (*RemoteStopResponse) String 

func (x *RemoteStopResponse) String() string

type RemoteTellGrainRequest added in v3.7.0 

type RemoteTellGrainRequest struct {
	Grain   *Grain     `protobuf:"bytes,1,opt,name=grain,proto3" json:"grain,omitempty"`
	Message *anypb.Any `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteTellGrainRequest) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use RemoteTellGrainRequest.ProtoReflect.Descriptor instead.

func (*RemoteTellGrainRequest) GetGrain added in v3.7.0 

func (x *RemoteTellGrainRequest) GetGrain() *Grain

func (*RemoteTellGrainRequest) GetMessage added in v3.7.0 

func (x *RemoteTellGrainRequest) GetMessage() *anypb.Any

func (*RemoteTellGrainRequest) ProtoMessage added in v3.7.0 

func (*RemoteTellGrainRequest) ProtoMessage()

func (*RemoteTellGrainRequest) ProtoReflect added in v3.7.0 

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

func (*RemoteTellGrainRequest) Reset added in v3.7.0 

func (x *RemoteTellGrainRequest) Reset()

func (*RemoteTellGrainRequest) String added in v3.7.0 

func (x *RemoteTellGrainRequest) String() string

type RemoteTellGrainResponse added in v3.7.0 

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

func (*RemoteTellGrainResponse) Descriptor deprecated added in v3.7.0 

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

Deprecated: Use RemoteTellGrainResponse.ProtoReflect.Descriptor instead.

func (*RemoteTellGrainResponse) ProtoMessage added in v3.7.0 

func (*RemoteTellGrainResponse) ProtoMessage()

func (*RemoteTellGrainResponse) ProtoReflect added in v3.7.0 

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

func (*RemoteTellGrainResponse) Reset added in v3.7.0 

func (x *RemoteTellGrainResponse) Reset()

func (*RemoteTellGrainResponse) String added in v3.7.0 

func (x *RemoteTellGrainResponse) String() string

type RemoteTellRequest 

type RemoteTellRequest struct {

	// Specifies the remote message to send
	RemoteMessages []*RemoteMessage `protobuf:"bytes,1,rep,name=remote_messages,json=remoteMessages,proto3" json:"remote_messages,omitempty"`
	// contains filtered or unexported fields
}

RemoteTell is used to send a message to an actor remotely

func (*RemoteTellRequest) Descriptor deprecated 

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

Deprecated: Use RemoteTellRequest.ProtoReflect.Descriptor instead.

func (*RemoteTellRequest) GetRemoteMessages added in v3.3.0 

func (x *RemoteTellRequest) GetRemoteMessages() []*RemoteMessage

func (*RemoteTellRequest) ProtoMessage 

func (*RemoteTellRequest) ProtoMessage()

func (*RemoteTellRequest) ProtoReflect 

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

func (*RemoteTellRequest) Reset 

func (x *RemoteTellRequest) Reset()

func (*RemoteTellRequest) String 

func (x *RemoteTellRequest) String() string

type RemoteTellResponse 

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

func (*RemoteTellResponse) Descriptor deprecated 

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

Deprecated: Use RemoteTellResponse.ProtoReflect.Descriptor instead.

func (*RemoteTellResponse) ProtoMessage 

func (*RemoteTellResponse) ProtoMessage()

func (*RemoteTellResponse) ProtoReflect 

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

func (*RemoteTellResponse) Reset 

func (x *RemoteTellResponse) Reset()

func (*RemoteTellResponse) String 

func (x *RemoteTellResponse) String() string

type RemovePeerActor added in v3.9.4 

type RemovePeerActor struct {

	// Specifies the peer address
	PeerAddress string `protobuf:"bytes,1,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"`
	// Specifies the remoting por
	// Specifies the actor name
	ActorName string `protobuf:"bytes,2,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemovePeerActor) Descriptor deprecated added in v3.9.4 

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

Deprecated: Use RemovePeerActor.ProtoReflect.Descriptor instead.

func (*RemovePeerActor) GetActorName added in v3.9.4 

func (x *RemovePeerActor) GetActorName() string

func (*RemovePeerActor) GetPeerAddress added in v3.9.4 

func (x *RemovePeerActor) GetPeerAddress() string

func (*RemovePeerActor) ProtoMessage added in v3.9.4 

func (*RemovePeerActor) ProtoMessage()

func (*RemovePeerActor) ProtoReflect added in v3.9.4 

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

func (*RemovePeerActor) Reset added in v3.9.4 

func (x *RemovePeerActor) Reset()

func (*RemovePeerActor) String added in v3.9.4 

func (x *RemovePeerActor) String() string

type RemovePeerGrain added in v3.9.4 

type RemovePeerGrain struct {

	// Specifies the peer address
	PeerAddress string   `protobuf:"bytes,1,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"`
	GrainId     *GrainId `protobuf:"bytes,2,opt,name=grain_id,json=grainId,proto3" json:"grain_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemovePeerGrain) Descriptor deprecated added in v3.9.4 

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

Deprecated: Use RemovePeerGrain.ProtoReflect.Descriptor instead.

func (*RemovePeerGrain) GetGrainId added in v3.9.4 

func (x *RemovePeerGrain) GetGrainId() *GrainId

func (*RemovePeerGrain) GetPeerAddress added in v3.9.4 

func (x *RemovePeerGrain) GetPeerAddress() string

func (*RemovePeerGrain) ProtoMessage added in v3.9.4 

func (*RemovePeerGrain) ProtoMessage()

func (*RemovePeerGrain) ProtoReflect added in v3.9.4 

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

func (*RemovePeerGrain) Reset added in v3.9.4 

func (x *RemovePeerGrain) Reset()

func (*RemovePeerGrain) String added in v3.9.4 

func (x *RemovePeerGrain) String() string

type RestartDirective 

type RestartDirective struct {

	// Specifies the maximum number of retries;
	// When reaching this number, the faulty actor is stopped
	MaxRetries uint32 `protobuf:"varint,1,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	// Specifies the time range to restart the faulty actor
	Timeout int64 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

RestartDirective defines supervisor restart directive

func (*RestartDirective) Descriptor deprecated 

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

Deprecated: Use RestartDirective.ProtoReflect.Descriptor instead.

func (*RestartDirective) GetMaxRetries 

func (x *RestartDirective) GetMaxRetries() uint32

func (*RestartDirective) GetTimeout 

func (x *RestartDirective) GetTimeout() int64

func (*RestartDirective) ProtoMessage 

func (*RestartDirective) ProtoMessage()

func (*RestartDirective) ProtoReflect 

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

func (*RestartDirective) Reset 

func (x *RestartDirective) Reset()

func (*RestartDirective) String 

func (x *RestartDirective) String() string

type ResumeDirective 

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

ResumeDirective defines the supervisor resume directive This ignores the failure and processes the next message, instead

func (*ResumeDirective) Descriptor deprecated 

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

Deprecated: Use ResumeDirective.ProtoReflect.Descriptor instead.

func (*ResumeDirective) ProtoMessage 

func (*ResumeDirective) ProtoMessage()

func (*ResumeDirective) ProtoReflect 

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

func (*ResumeDirective) Reset 

func (x *ResumeDirective) Reset()

func (*ResumeDirective) String 

func (x *ResumeDirective) String() string

type SendDeadletter added in v3.9.5 

type SendDeadletter struct {

	// Specifies the deadletter to emit.
	Deadletter *goaktpb.Deadletter `protobuf:"bytes,1,opt,name=deadletter,proto3" json:"deadletter,omitempty"`
	// contains filtered or unexported fields
}

SendDeadletter is used to emit a single deadletter event. The deadletter field contains the details of the failed message.

func (*SendDeadletter) Descriptor deprecated added in v3.9.5 

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

Deprecated: Use SendDeadletter.ProtoReflect.Descriptor instead.

func (*SendDeadletter) GetDeadletter added in v3.9.5 

func (x *SendDeadletter) GetDeadletter() *goaktpb.Deadletter

func (*SendDeadletter) ProtoMessage added in v3.9.5 

func (*SendDeadletter) ProtoMessage()

func (*SendDeadletter) ProtoReflect added in v3.9.5 

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

func (*SendDeadletter) Reset added in v3.9.5 

func (x *SendDeadletter) Reset()

func (*SendDeadletter) String added in v3.9.5 

func (x *SendDeadletter) String() string

type StopDirective 

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

StopDirective defines the supervisor stop directive

func (*StopDirective) Descriptor deprecated 

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

Deprecated: Use StopDirective.ProtoReflect.Descriptor instead.

func (*StopDirective) ProtoMessage 

func (*StopDirective) ProtoMessage()

func (*StopDirective) ProtoReflect 

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

func (*StopDirective) Reset 

func (x *StopDirective) Reset()

func (*StopDirective) String 

func (x *StopDirective) String() string

type Strategy 

type Strategy int32
const (
	Strategy_STRATEGY_ONE_FOR_ONE Strategy = 0
	Strategy_STRATEGY_ONE_FOR_ALL Strategy = 1
)

func (Strategy) Descriptor 

func (Strategy) Descriptor() protoreflect.EnumDescriptor

func (Strategy) Enum 

func (x Strategy) Enum() *Strategy

func (Strategy) EnumDescriptor deprecated 

func (Strategy) EnumDescriptor() ([]byte, []int)

Deprecated: Use Strategy.Descriptor instead.

func (Strategy) Number 

func (x Strategy) Number() protoreflect.EnumNumber

func (Strategy) String 

func (x Strategy) String() string

func (Strategy) Type 

func (Strategy) Type() protoreflect.EnumType

type TimeBasedPassivation added in v3.6.0 

type TimeBasedPassivation struct {
	PassivateAfter *durationpb.Duration `protobuf:"bytes,1,opt,name=passivate_after,json=passivateAfter,proto3" json:"passivate_after,omitempty"`
	// contains filtered or unexported fields
}

TimeBasedPassivation defines a strategy where an actor is passivated after a specified period of inactivity.

passivate_after: 

The duration after which an idle actor should be stopped.
This helps free up system resources by removing actors that haven't
received messages for a defined time window.

func (*TimeBasedPassivation) Descriptor deprecated added in v3.6.0 

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

Deprecated: Use TimeBasedPassivation.ProtoReflect.Descriptor instead.

func (*TimeBasedPassivation) GetPassivateAfter added in v3.6.0 

func (x *TimeBasedPassivation) GetPassivateAfter() *durationpb.Duration

func (*TimeBasedPassivation) ProtoMessage added in v3.6.0 

func (*TimeBasedPassivation) ProtoMessage()

func (*TimeBasedPassivation) ProtoReflect added in v3.6.0 

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

func (*TimeBasedPassivation) Reset added in v3.6.0 

func (x *TimeBasedPassivation) Reset()

func (*TimeBasedPassivation) String added in v3.6.0 

func (x *TimeBasedPassivation) String() string

type TopicMessage added in v3.9.3 

type TopicMessage struct {

	// Specifies the message unique id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Specifies the topic
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Specifies the message
	Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicMessage) Descriptor deprecated added in v3.9.3 

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

Deprecated: Use TopicMessage.ProtoReflect.Descriptor instead.

func (*TopicMessage) GetId added in v3.9.3 

func (x *TopicMessage) GetId() string

func (*TopicMessage) GetMessage added in v3.9.3 

func (x *TopicMessage) GetMessage() *anypb.Any

func (*TopicMessage) GetTopic added in v3.9.3 

func (x *TopicMessage) GetTopic() string

func (*TopicMessage) ProtoMessage added in v3.9.3 

func (*TopicMessage) ProtoMessage()

func (*TopicMessage) ProtoReflect added in v3.9.3 

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

func (*TopicMessage) Reset added in v3.9.3 

func (x *TopicMessage) Reset()

func (*TopicMessage) String added in v3.9.3 

func (x *TopicMessage) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.