internalpb

package
v3.0.0 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2025 License: MIT Imports: 8 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_lsm_proto protoreflect.FileDescriptor
View Source 
var File_internal_nats_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 ActorRef 

type ActorRef struct {

	// Specifies the actor address
	ActorAddress *goaktpb.Address `protobuf:"bytes,1,opt,name=actor_address,json=actorAddress,proto3" json:"actor_address,omitempty"`
	// Specifies the actor type
	ActorType string `protobuf:"bytes,2,opt,name=actor_type,json=actorType,proto3" json:"actor_type,omitempty"`
	// contains filtered or unexported fields
}

ActorRef represents the actor information on the wire.

func (*ActorRef) Descriptor deprecated 

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

Deprecated: Use ActorRef.ProtoReflect.Descriptor instead.

func (*ActorRef) GetActorAddress 

func (x *ActorRef) GetActorAddress() *goaktpb.Address

func (*ActorRef) GetActorType 

func (x *ActorRef) GetActorType() string

func (*ActorRef) ProtoMessage 

func (*ActorRef) ProtoMessage()

func (*ActorRef) ProtoReflect 

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

func (*ActorRef) Reset 

func (x *ActorRef) Reset()

func (*ActorRef) String 

func (x *ActorRef) String() string

type DeadlettersCount 

type DeadlettersCount struct {

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

func (*DeadlettersCount) Descriptor deprecated 

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

Deprecated: Use DeadlettersCount.ProtoReflect.Descriptor instead.

func (*DeadlettersCount) GetTotalCount 

func (x *DeadlettersCount) GetTotalCount() int64

func (*DeadlettersCount) ProtoMessage 

func (*DeadlettersCount) ProtoMessage()

func (*DeadlettersCount) ProtoReflect 

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

func (*DeadlettersCount) Reset 

func (x *DeadlettersCount) Reset()

func (*DeadlettersCount) String 

func (x *DeadlettersCount) String() string

type EmitDeadletter 

type EmitDeadletter struct {

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

func (*EmitDeadletter) Descriptor deprecated 

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

Deprecated: Use EmitDeadletter.ProtoReflect.Descriptor instead.

func (*EmitDeadletter) GetDeadletter 

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

func (*EmitDeadletter) ProtoMessage 

func (*EmitDeadletter) ProtoMessage()

func (*EmitDeadletter) ProtoReflect 

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

func (*EmitDeadletter) Reset 

func (x *EmitDeadletter) Reset()

func (*EmitDeadletter) String 

func (x *EmitDeadletter) String() string

type Entry 

type Entry struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Tombstone bool   `protobuf:"varint,3,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	// contains filtered or unexported fields
}

func (*Entry) Descriptor deprecated 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetKey 

func (x *Entry) GetKey() string

func (*Entry) GetTombstone 

func (x *Entry) GetTombstone() bool

func (*Entry) GetValue 

func (x *Entry) GetValue() []byte

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

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

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) 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 GetDeadletters 

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

func (*GetDeadletters) Descriptor deprecated 

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

Deprecated: Use GetDeadletters.ProtoReflect.Descriptor instead.

func (*GetDeadletters) ProtoMessage 

func (*GetDeadletters) ProtoMessage()

func (*GetDeadletters) ProtoReflect 

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

func (*GetDeadletters) Reset 

func (x *GetDeadletters) Reset()

func (*GetDeadletters) String 

func (x *GetDeadletters) String() string

type GetDeadlettersCount 

type GetDeadlettersCount struct {

	// optional 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
}

func (*GetDeadlettersCount) Descriptor deprecated 

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

Deprecated: Use GetDeadlettersCount.ProtoReflect.Descriptor instead.

func (*GetDeadlettersCount) GetActorId 

func (x *GetDeadlettersCount) GetActorId() string

func (*GetDeadlettersCount) ProtoMessage 

func (*GetDeadlettersCount) ProtoMessage()

func (*GetDeadlettersCount) ProtoReflect 

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

func (*GetDeadlettersCount) Reset 

func (x *GetDeadlettersCount) Reset()

func (*GetDeadlettersCount) String 

func (x *GetDeadlettersCount) 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 HandleFault 

type HandleFault struct {

	// Specifies the actor id
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// Specifies the message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Specifies the directive
	//
	// Types that are valid to be assigned to Directive:
	//
	//	*HandleFault_Stop
	//	*HandleFault_Resume
	//	*HandleFault_Restart
	//	*HandleFault_Escalate
	Directive isHandleFault_Directive `protobuf_oneof:"directive"`
	// Specifies the strategy
	Strategy Strategy `protobuf:"varint,7,opt,name=strategy,proto3,enum=internalpb.Strategy" json:"strategy,omitempty"`
	// contains filtered or unexported fields
}

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

func (*HandleFault) Descriptor deprecated 

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

Deprecated: Use HandleFault.ProtoReflect.Descriptor instead.

func (*HandleFault) GetActorId 

func (x *HandleFault) GetActorId() string

func (*HandleFault) GetDirective 

func (x *HandleFault) GetDirective() isHandleFault_Directive

func (*HandleFault) GetEscalate 

func (x *HandleFault) GetEscalate() *EscalateDirective

func (*HandleFault) GetMessage 

func (x *HandleFault) GetMessage() string

func (*HandleFault) GetRestart 

func (x *HandleFault) GetRestart() *RestartDirective

func (*HandleFault) GetResume 

func (x *HandleFault) GetResume() *ResumeDirective

func (*HandleFault) GetStop 

func (x *HandleFault) GetStop() *StopDirective

func (*HandleFault) GetStrategy 

func (x *HandleFault) GetStrategy() Strategy

func (*HandleFault) ProtoMessage 

func (*HandleFault) ProtoMessage()

func (*HandleFault) ProtoReflect 

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

func (*HandleFault) Reset 

func (x *HandleFault) Reset()

func (*HandleFault) String 

func (x *HandleFault) String() string

type HandleFault_Escalate 

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

type HandleFault_Restart 

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

type HandleFault_Resume 

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

type HandleFault_Stop 

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

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 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 -> actorKind
	Actors map[string]string `` /* 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]string

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 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 RemoteAskRequest 

type RemoteAskRequest struct {

	// Specifies the remote message to send
	RemoteMessage *RemoteMessage `protobuf:"bytes,1,opt,name=remote_message,json=remoteMessage,proto3" json:"remote_message,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) GetRemoteMessage 

func (x *RemoteAskRequest) GetRemoteMessage() *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
	Message *anypb.Any `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteAskResponse) Descriptor deprecated 

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

Deprecated: Use RemoteAskResponse.ProtoReflect.Descriptor instead.

func (*RemoteAskResponse) GetMessage 

func (x *RemoteAskResponse) GetMessage() *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 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"`
	// 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) GetHost 

func (x *RemoteSpawnRequest) GetHost() string

func (*RemoteSpawnRequest) GetPort 

func (x *RemoteSpawnRequest) GetPort() int32

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 RemoteTellRequest 

type RemoteTellRequest struct {

	// Specifies the remote message to send
	RemoteMessage *RemoteMessage `protobuf:"bytes,1,opt,name=remote_message,json=remoteMessage,proto3" json:"remote_message,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) GetRemoteMessage 

func (x *RemoteTellRequest) GetRemoteMessage() *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 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 process 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 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

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.