goaktv1

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_goakt_v1_remoting_proto protoreflect.FileDescriptor
View Source 
var File_goakt_v1_wireactor_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type RemoteAskRequest 

type RemoteAskRequest struct {
	RemoteMessage *v1.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. With this type of message the receiver cannot communicate back to Sender except reply the message with a response. This one-way communication

func (*RemoteAskRequest) Descriptor deprecated 

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

Deprecated: Use RemoteAskRequest.ProtoReflect.Descriptor instead.

func (*RemoteAskRequest) GetRemoteMessage added in v0.2.0 

func (x *RemoteAskRequest) GetRemoteMessage() *v1.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 *v1.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() *v1.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 RemoteTellRequest 

type RemoteTellRequest struct {
	RemoteMessage *v1.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 by another actor This is the only way remote actors can interact with each other. The actor on the other line can reply to the sender by using the Sender in the message

func (*RemoteTellRequest) Descriptor deprecated 

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

Deprecated: Use RemoteTellRequest.ProtoReflect.Descriptor instead.

func (*RemoteTellRequest) GetRemoteMessage 

func (x *RemoteTellRequest) GetRemoteMessage() *v1.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 *v1.Address `protobuf:"bytes,2,opt,name=actor_address,json=actorAddress,proto3" json:"actor_address,omitempty"`
	// Specifies the actor payload. The payload is used
	// to recreate this actor in case the node hosting the actor is dead and we want to recreate the given actor
	// on another node of the cluster
	ActorPayload []byte `protobuf:"bytes,3,opt,name=actor_payload,json=actorPayload,proto3" json:"actor_payload,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() *v1.Address

func (*WireActor) GetActorName 

func (x *WireActor) GetActorName() string

func (*WireActor) GetActorPayload 

func (x *WireActor) GetActorPayload() []byte

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.