internalpb

package
v1.6.3 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2024 License: MIT Imports: 6 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 File_internal_nats_proto protoreflect.FileDescriptor
View Source 
var File_internal_remoting_proto protoreflect.FileDescriptor
View Source 
var File_internal_wireactor_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

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 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"`
	// 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) 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 added in v1.6.0 

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 added in v1.6.0 

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

Deprecated: Use RemoteSpawnRequest.ProtoReflect.Descriptor instead.

func (*RemoteSpawnRequest) GetActorName added in v1.6.0 

func (x *RemoteSpawnRequest) GetActorName() string

func (*RemoteSpawnRequest) GetActorType added in v1.6.0 

func (x *RemoteSpawnRequest) GetActorType() string

func (*RemoteSpawnRequest) GetHost added in v1.6.0 

func (x *RemoteSpawnRequest) GetHost() string

func (*RemoteSpawnRequest) GetPort added in v1.6.0 

func (x *RemoteSpawnRequest) GetPort() int32

func (*RemoteSpawnRequest) ProtoMessage added in v1.6.0 

func (*RemoteSpawnRequest) ProtoMessage()

func (*RemoteSpawnRequest) ProtoReflect added in v1.6.0 

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

func (*RemoteSpawnRequest) Reset added in v1.6.0 

func (x *RemoteSpawnRequest) Reset()

func (*RemoteSpawnRequest) String added in v1.6.0 

func (x *RemoteSpawnRequest) String() string

type RemoteSpawnResponse added in v1.6.0 

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

func (*RemoteSpawnResponse) Descriptor deprecated added in v1.6.0 

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

Deprecated: Use RemoteSpawnResponse.ProtoReflect.Descriptor instead.

func (*RemoteSpawnResponse) ProtoMessage added in v1.6.0 

func (*RemoteSpawnResponse) ProtoMessage()

func (*RemoteSpawnResponse) ProtoReflect added in v1.6.0 

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

func (*RemoteSpawnResponse) Reset added in v1.6.0 

func (x *RemoteSpawnResponse) Reset()

func (*RemoteSpawnResponse) String added in v1.6.0 

func (x *RemoteSpawnResponse) String() string

type RemoteStopRequest added in v1.5.1 

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 added in v1.5.1 

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

Deprecated: Use RemoteStopRequest.ProtoReflect.Descriptor instead.

func (*RemoteStopRequest) GetHost added in v1.5.1 

func (x *RemoteStopRequest) GetHost() string

func (*RemoteStopRequest) GetName added in v1.5.1 

func (x *RemoteStopRequest) GetName() string

func (*RemoteStopRequest) GetPort added in v1.5.1 

func (x *RemoteStopRequest) GetPort() int32

func (*RemoteStopRequest) ProtoMessage added in v1.5.1 

func (*RemoteStopRequest) ProtoMessage()

func (*RemoteStopRequest) ProtoReflect added in v1.5.1 

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

func (*RemoteStopRequest) Reset added in v1.5.1 

func (x *RemoteStopRequest) Reset()

func (*RemoteStopRequest) String added in v1.5.1 

func (x *RemoteStopRequest) String() string

type RemoteStopResponse added in v1.5.1 

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

func (*RemoteStopResponse) Descriptor deprecated added in v1.5.1 

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

Deprecated: Use RemoteStopResponse.ProtoReflect.Descriptor instead.

func (*RemoteStopResponse) ProtoMessage added in v1.5.1 

func (*RemoteStopResponse) ProtoMessage()

func (*RemoteStopResponse) ProtoReflect added in v1.5.1 

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

func (*RemoteStopResponse) Reset added in v1.5.1 

func (x *RemoteStopResponse) Reset()

func (*RemoteStopResponse) String added in v1.5.1 

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 WireActor 

type WireActor struct {

	// Specifies the actor name.
	// The actor name can be either the actor FQN or an alias
	ActorName string `protobuf:"bytes,1,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	// Specifies the actor address
	ActorAddress *goaktpb.Address `protobuf:"bytes,2,opt,name=actor_address,json=actorAddress,proto3" json:"actor_address,omitempty"`
	// Specifies the actor full path
	ActorPath string `protobuf:"bytes,3,opt,name=actor_path,json=actorPath,proto3" json:"actor_path,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
}

WireActor represents the actor information on the wire.

func (*WireActor) Descriptor deprecated 

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

Deprecated: Use WireActor.ProtoReflect.Descriptor instead.

func (*WireActor) GetActorAddress 

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

func (*WireActor) GetActorName 

func (x *WireActor) GetActorName() string

func (*WireActor) GetActorPath 

func (x *WireActor) GetActorPath() string

func (*WireActor) GetActorType added in v1.6.2 

func (x *WireActor) GetActorType() string

func (*WireActor) ProtoMessage 

func (*WireActor) ProtoMessage()

func (*WireActor) ProtoReflect 

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

func (*WireActor) Reset 

func (x *WireActor) Reset()

func (*WireActor) String 

func (x *WireActor) 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.