goaktpb

package
v2.3.1 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2024 License: MIT Imports: 6 Imported by: 14

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

Source Files

View all Source files

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.