eventspb

package
v1.4.4 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_events_v1_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActorChildCreated added in v1.4.0 

type ActorChildCreated struct {

	// Specifies the actor address
	Address *v1.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Specifies the parent address
	Parent *v1.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 added in v1.4.0 

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

Deprecated: Use ActorChildCreated.ProtoReflect.Descriptor instead.

func (*ActorChildCreated) GetAddress added in v1.4.0 

func (x *ActorChildCreated) GetAddress() *v1.Address

func (*ActorChildCreated) GetCreatedAt added in v1.4.0 

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

func (*ActorChildCreated) GetParent added in v1.4.0 

func (x *ActorChildCreated) GetParent() *v1.Address

func (*ActorChildCreated) ProtoMessage added in v1.4.0 

func (*ActorChildCreated) ProtoMessage()

func (*ActorChildCreated) ProtoReflect added in v1.4.0 

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

func (*ActorChildCreated) Reset added in v1.4.0 

func (x *ActorChildCreated) Reset()

func (*ActorChildCreated) String added in v1.4.0 

func (x *ActorChildCreated) String() string

type ActorPassivated added in v1.4.0 

type ActorPassivated struct {

	// Specifies the actor address
	Address *v1.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 added in v1.4.0 

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

Deprecated: Use ActorPassivated.ProtoReflect.Descriptor instead.

func (*ActorPassivated) GetAddress added in v1.4.0 

func (x *ActorPassivated) GetAddress() *v1.Address

func (*ActorPassivated) GetPassivatedAt added in v1.4.0 

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

func (*ActorPassivated) ProtoMessage added in v1.4.0 

func (*ActorPassivated) ProtoMessage()

func (*ActorPassivated) ProtoReflect added in v1.4.0 

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

func (*ActorPassivated) Reset added in v1.4.0 

func (x *ActorPassivated) Reset()

func (*ActorPassivated) String added in v1.4.0 

func (x *ActorPassivated) String() string

type ActorRestarted added in v1.4.0 

type ActorRestarted struct {

	// Specifies the actor address
	Address *v1.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 added in v1.4.0 

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

Deprecated: Use ActorRestarted.ProtoReflect.Descriptor instead.

func (*ActorRestarted) GetAddress added in v1.4.0 

func (x *ActorRestarted) GetAddress() *v1.Address

func (*ActorRestarted) GetRestartedAt added in v1.4.0 

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

func (*ActorRestarted) ProtoMessage added in v1.4.0 

func (*ActorRestarted) ProtoMessage()

func (*ActorRestarted) ProtoReflect added in v1.4.0 

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

func (*ActorRestarted) Reset added in v1.4.0 

func (x *ActorRestarted) Reset()

func (*ActorRestarted) String added in v1.4.0 

func (x *ActorRestarted) String() string

type ActorStarted added in v1.4.0 

type ActorStarted struct {

	// Specifies the actor address
	Address *v1.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 added in v1.4.0 

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

Deprecated: Use ActorStarted.ProtoReflect.Descriptor instead.

func (*ActorStarted) GetAddress added in v1.4.0 

func (x *ActorStarted) GetAddress() *v1.Address

func (*ActorStarted) GetStartedAt added in v1.4.0 

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

func (*ActorStarted) ProtoMessage added in v1.4.0 

func (*ActorStarted) ProtoMessage()

func (*ActorStarted) ProtoReflect added in v1.4.0 

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

func (*ActorStarted) Reset added in v1.4.0 

func (x *ActorStarted) Reset()

func (*ActorStarted) String added in v1.4.0 

func (x *ActorStarted) String() string

type ActorStopped added in v1.4.0 

type ActorStopped struct {

	// Specifies the actor address
	Address *v1.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 added in v1.4.0 

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

Deprecated: Use ActorStopped.ProtoReflect.Descriptor instead.

func (*ActorStopped) GetAddress added in v1.4.0 

func (x *ActorStopped) GetAddress() *v1.Address

func (*ActorStopped) GetStoppedAt added in v1.4.0 

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

func (*ActorStopped) ProtoMessage added in v1.4.0 

func (*ActorStopped) ProtoMessage()

func (*ActorStopped) ProtoReflect added in v1.4.0 

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

func (*ActorStopped) Reset added in v1.4.0 

func (x *ActorStopped) Reset()

func (*ActorStopped) String added in v1.4.0 

func (x *ActorStopped) String() string

type Deadletter added in v1.4.0 

type Deadletter struct {

	// Specifies the sender's address
	Sender *v1.Address `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// Specifies the actor address
	Receiver *v1.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 added in v1.4.0 

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

Deprecated: Use Deadletter.ProtoReflect.Descriptor instead.

func (*Deadletter) GetMessage added in v1.4.0 

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

func (*Deadletter) GetReason added in v1.4.0 

func (x *Deadletter) GetReason() string

func (*Deadletter) GetReceiver added in v1.4.0 

func (x *Deadletter) GetReceiver() *v1.Address

func (*Deadletter) GetSendTime added in v1.4.0 

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

func (*Deadletter) GetSender added in v1.4.0 

func (x *Deadletter) GetSender() *v1.Address

func (*Deadletter) ProtoMessage added in v1.4.0 

func (*Deadletter) ProtoMessage()

func (*Deadletter) ProtoReflect added in v1.4.0 

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

func (*Deadletter) Reset added in v1.4.0 

func (x *Deadletter) Reset()

func (*Deadletter) String added in v1.4.0 

func (x *Deadletter) String() string

type NodeJoined added in v1.4.0 

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

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

Deprecated: Use NodeJoined.ProtoReflect.Descriptor instead.

func (*NodeJoined) GetAddress added in v1.4.0 

func (x *NodeJoined) GetAddress() string

func (*NodeJoined) GetTimestamp added in v1.4.0 

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

func (*NodeJoined) ProtoMessage added in v1.4.0 

func (*NodeJoined) ProtoMessage()

func (*NodeJoined) ProtoReflect added in v1.4.0 

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

func (*NodeJoined) Reset added in v1.4.0 

func (x *NodeJoined) Reset()

func (*NodeJoined) String added in v1.4.0 

func (x *NodeJoined) String() string

type NodeLeft added in v1.4.0 

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

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

Deprecated: Use NodeLeft.ProtoReflect.Descriptor instead.

func (*NodeLeft) GetAddress added in v1.4.0 

func (x *NodeLeft) GetAddress() string

func (*NodeLeft) GetTimestamp added in v1.4.0 

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

func (*NodeLeft) ProtoMessage added in v1.4.0 

func (*NodeLeft) ProtoMessage()

func (*NodeLeft) ProtoReflect added in v1.4.0 

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

func (*NodeLeft) Reset added in v1.4.0 

func (x *NodeLeft) Reset()

func (*NodeLeft) String added in v1.4.0 

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