goaktpb

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 File_goakt_goakt_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActorChildCreated

type ActorChildCreated struct {

	// Specifies the actor address
	Address *Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the parent address
	Parent *Address `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// Specifies the started time
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

ActorChildCreated defines the child actor created event

func (*ActorChildCreated) Descriptor deprecated

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

Deprecated: Use ActorChildCreated.ProtoReflect.Descriptor instead.

func (*ActorChildCreated) GetAddress

func (x *ActorChildCreated) GetAddress() *Address

func (*ActorChildCreated) GetCreatedAt

func (x *ActorChildCreated) GetCreatedAt() *timestamppb.Timestamp

func (*ActorChildCreated) GetParent

func (x *ActorChildCreated) GetParent() *Address

func (*ActorChildCreated) ProtoMessage

func (*ActorChildCreated) ProtoMessage()

func (*ActorChildCreated) ProtoReflect

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

func (*ActorChildCreated) Reset

func (x *ActorChildCreated) Reset()

func (*ActorChildCreated) String

func (x *ActorChildCreated) String() string

type ActorPassivated

type ActorPassivated struct {

	// Specifies the actor address
	Address *Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the passivation time
	PassivatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=passivated_at,json=passivatedAt,proto3" json:"passivated_at,omitempty"`
	// contains filtered or unexported fields
}

ActorPassivated define the actor passivated event

func (*ActorPassivated) Descriptor deprecated

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

Deprecated: Use ActorPassivated.ProtoReflect.Descriptor instead.

func (*ActorPassivated) GetAddress

func (x *ActorPassivated) GetAddress() *Address

func (*ActorPassivated) GetPassivatedAt

func (x *ActorPassivated) GetPassivatedAt() *timestamppb.Timestamp

func (*ActorPassivated) ProtoMessage

func (*ActorPassivated) ProtoMessage()

func (*ActorPassivated) ProtoReflect

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

func (*ActorPassivated) Reset

func (x *ActorPassivated) Reset()

func (*ActorPassivated) String

func (x *ActorPassivated) String() string

type ActorRestarted

type ActorRestarted struct {

	// Specifies the actor address
	Address *Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the stop time
	RestartedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=restarted_at,json=restartedAt,proto3" json:"restarted_at,omitempty"`
	// contains filtered or unexported fields
}

ActorRestarted defines the actor restarted event

func (*ActorRestarted) Descriptor deprecated

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

Deprecated: Use ActorRestarted.ProtoReflect.Descriptor instead.

func (*ActorRestarted) GetAddress

func (x *ActorRestarted) GetAddress() *Address

func (*ActorRestarted) GetRestartedAt

func (x *ActorRestarted) GetRestartedAt() *timestamppb.Timestamp

func (*ActorRestarted) ProtoMessage

func (*ActorRestarted) ProtoMessage()

func (*ActorRestarted) ProtoReflect

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

func (*ActorRestarted) Reset

func (x *ActorRestarted) Reset()

func (*ActorRestarted) String

func (x *ActorRestarted) String() string

type ActorStarted

type ActorStarted struct {

	// Specifies the actor address
	Address *Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the started time
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// contains filtered or unexported fields
}

ActorStarted defines the actor started event

func (*ActorStarted) Descriptor deprecated

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

Deprecated: Use ActorStarted.ProtoReflect.Descriptor instead.

func (*ActorStarted) GetAddress

func (x *ActorStarted) GetAddress() *Address

func (*ActorStarted) GetStartedAt

func (x *ActorStarted) GetStartedAt() *timestamppb.Timestamp

func (*ActorStarted) ProtoMessage

func (*ActorStarted) ProtoMessage()

func (*ActorStarted) ProtoReflect

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

func (*ActorStarted) Reset

func (x *ActorStarted) Reset()

func (*ActorStarted) String

func (x *ActorStarted) String() string

type ActorStopped

type ActorStopped struct {

	// Specifies the actor address
	Address *Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the stop time
	StoppedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=stopped_at,json=stoppedAt,proto3" json:"stopped_at,omitempty"`
	// contains filtered or unexported fields
}

ActorStopped defines the actor stopped event

func (*ActorStopped) Descriptor deprecated

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

Deprecated: Use ActorStopped.ProtoReflect.Descriptor instead.

func (*ActorStopped) GetAddress

func (x *ActorStopped) GetAddress() *Address

func (*ActorStopped) GetStoppedAt

func (x *ActorStopped) GetStoppedAt() *timestamppb.Timestamp

func (*ActorStopped) ProtoMessage

func (*ActorStopped) ProtoMessage()

func (*ActorStopped) ProtoReflect

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

func (*ActorStopped) Reset

func (x *ActorStopped) Reset()

func (*ActorStopped) String

func (x *ActorStopped) String() string

type Address

type Address 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"`
	// Specifies the actor unique id on the remote host
	Id string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Address represents an actor address

func (*Address) Descriptor deprecated

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

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetHost

func (x *Address) GetHost() string

func (*Address) GetId

func (x *Address) GetId() string

func (*Address) GetName

func (x *Address) GetName() string

func (*Address) GetPort

func (x *Address) GetPort() int32

func (*Address) ProtoMessage

func (*Address) ProtoMessage()

func (*Address) ProtoReflect

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

func (*Address) Reset

func (x *Address) Reset()

func (*Address) String

func (x *Address) String() string

type Deadletter

type Deadletter struct {

	// Specifies the sender's address
	Sender *Address `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// Specifies the actor address
	Receiver *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"`
	// Specifies the message send time
	SendTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"`
	// Specifies the reason why the deadletter
	Reason string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

Deadletter defines the deadletter event

func (*Deadletter) Descriptor deprecated

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

Deprecated: Use Deadletter.ProtoReflect.Descriptor instead.

func (*Deadletter) GetMessage

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

func (*Deadletter) GetReason

func (x *Deadletter) GetReason() string

func (*Deadletter) GetReceiver

func (x *Deadletter) GetReceiver() *Address

func (*Deadletter) GetSendTime

func (x *Deadletter) GetSendTime() *timestamppb.Timestamp

func (*Deadletter) GetSender

func (x *Deadletter) GetSender() *Address

func (*Deadletter) ProtoMessage

func (*Deadletter) ProtoMessage()

func (*Deadletter) ProtoReflect

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

func (*Deadletter) Reset

func (x *Deadletter) Reset()

func (*Deadletter) String

func (x *Deadletter) String() string

type NodeJoined

type NodeJoined struct {

	// Specifies the node address
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the timestamp
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

NodeJoined defines the node joined event

func (*NodeJoined) Descriptor deprecated

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

Deprecated: Use NodeJoined.ProtoReflect.Descriptor instead.

func (*NodeJoined) GetAddress

func (x *NodeJoined) GetAddress() string

func (*NodeJoined) GetTimestamp

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

func (*NodeJoined) ProtoMessage

func (*NodeJoined) ProtoMessage()

func (*NodeJoined) ProtoReflect

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

func (*NodeJoined) Reset

func (x *NodeJoined) Reset()

func (*NodeJoined) String

func (x *NodeJoined) String() string

type NodeLeft

type NodeLeft struct {

	// Specifies the node address
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the timestamp
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

NodeLeft defines the node left event

func (*NodeLeft) Descriptor deprecated

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

Deprecated: Use NodeLeft.ProtoReflect.Descriptor instead.

func (*NodeLeft) GetAddress

func (x *NodeLeft) GetAddress() string

func (*NodeLeft) GetTimestamp

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

func (*NodeLeft) ProtoMessage

func (*NodeLeft) ProtoMessage()

func (*NodeLeft) ProtoReflect

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

func (*NodeLeft) Reset

func (x *NodeLeft) Reset()

func (*NodeLeft) String

func (x *NodeLeft) String() string

type PoisonPill

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

PoisonPill is sent the stop an actor. It is enqueued as ordinary messages. It will be handled after messages that were already queued in the mailbox.

func (*PoisonPill) Descriptor deprecated

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

Deprecated: Use PoisonPill.ProtoReflect.Descriptor instead.

func (*PoisonPill) ProtoMessage

func (*PoisonPill) ProtoMessage()

func (*PoisonPill) ProtoReflect

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

func (*PoisonPill) Reset

func (x *PoisonPill) Reset()

func (*PoisonPill) String

func (x *PoisonPill) String() string

type PostStart

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

PostStart is used when an actor has successfully started

func (*PostStart) Descriptor deprecated

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

Deprecated: Use PostStart.ProtoReflect.Descriptor instead.

func (*PostStart) ProtoMessage

func (*PostStart) ProtoMessage()

func (*PostStart) ProtoReflect

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

func (*PostStart) Reset

func (x *PostStart) Reset()

func (*PostStart) String

func (x *PostStart) String() string

type PreStart

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

PreStart is used when an actor is about to start

func (*PreStart) Descriptor deprecated

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

Deprecated: Use PreStart.ProtoReflect.Descriptor instead.

func (*PreStart) ProtoMessage

func (*PreStart) ProtoMessage()

func (*PreStart) ProtoReflect

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

func (*PreStart) Reset

func (x *PreStart) Reset()

func (*PreStart) String

func (x *PreStart) String() string

type Terminated

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

Terminated is used to notify watching actors of the shutdown of its child actor.

func (*Terminated) Descriptor deprecated

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

Deprecated: Use Terminated.ProtoReflect.Descriptor instead.

func (*Terminated) ProtoMessage

func (*Terminated) ProtoMessage()

func (*Terminated) ProtoReflect

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

func (*Terminated) Reset

func (x *Terminated) Reset()

func (*Terminated) String

func (x *Terminated) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL