akka

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PatternType_name = map[int32]string{
		0: "PARENT",
		1: "CHILD_NAME",
		2: "CHILD_PATTERN",
	}
	PatternType_value = map[string]int32{
		"PARENT":        0,
		"CHILD_NAME":    1,
		"CHILD_PATTERN": 2,
	}
)

Enum value maps for PatternType.

View Source 
var (
	SystemMessage_Type_name = map[int32]string{
		0: "CREATE",
		1: "RECREATE",
		2: "SUSPEND",
		3: "RESUME",
		4: "TERMINATE",
		5: "SUPERVISE",
		6: "WATCH",
		7: "UNWATCH",
		8: "FAILED",
		9: "DEATHWATCH_NOTIFICATION",
	}
	SystemMessage_Type_value = map[string]int32{
		"CREATE":                  0,
		"RECREATE":                1,
		"SUSPEND":                 2,
		"RESUME":                  3,
		"TERMINATE":               4,
		"SUPERVISE":               5,
		"WATCH":                   6,
		"UNWATCH":                 7,
		"FAILED":                  8,
		"DEATHWATCH_NOTIFICATION": 9,
	}
)

Enum value maps for SystemMessage_Type.

View Source 
var (
	CommandType_name = map[int32]string{
		1: "ASSOCIATE",
		2: "DISASSOCIATE",
		3: "HEARTBEAT",
		4: "DISASSOCIATE_SHUTTING_DOWN",
		5: "DISASSOCIATE_QUARANTINED",
	}
	CommandType_value = map[string]int32{
		"ASSOCIATE":                  1,
		"DISASSOCIATE":               2,
		"HEARTBEAT":                  3,
		"DISASSOCIATE_SHUTTING_DOWN": 4,
		"DISASSOCIATE_QUARANTINED":   5,
	}
)

Enum value maps for CommandType.

View Source 
var (
	TimeUnit_name = map[int32]string{
		1: "NANOSECONDS",
		2: "MICROSECONDS",
		3: "MILLISECONDS",
		4: "SECONDS",
		5: "MINUTES",
		6: "HOURS",
		7: "DAYS",
	}
	TimeUnit_value = map[string]int32{
		"NANOSECONDS":  1,
		"MICROSECONDS": 2,
		"MILLISECONDS": 3,
		"SECONDS":      4,
		"MINUTES":      5,
		"HOURS":        6,
		"DAYS":         7,
	}
)

Enum value maps for TimeUnit.

View Source 
var File_ArteryControlFormats_proto protoreflect.FileDescriptor
View Source 
var File_ContainerFormats_proto protoreflect.FileDescriptor
View Source 
var File_SystemMessageFormats_proto protoreflect.FileDescriptor
View Source 
var File_WireFormats_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AckAndEnvelopeContainer 

type AckAndEnvelopeContainer struct {
	Ack      *AcknowledgementInfo `protobuf:"bytes,1,opt,name=ack" json:"ack,omitempty"`
	Envelope *RemoteEnvelope      `protobuf:"bytes,2,opt,name=envelope" json:"envelope,omitempty"`
	// contains filtered or unexported fields
}

func (*AckAndEnvelopeContainer) Descriptor deprecated 

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

Deprecated: Use AckAndEnvelopeContainer.ProtoReflect.Descriptor instead.

func (*AckAndEnvelopeContainer) GetAck 

func (x *AckAndEnvelopeContainer) GetAck() *AcknowledgementInfo

func (*AckAndEnvelopeContainer) GetEnvelope 

func (x *AckAndEnvelopeContainer) GetEnvelope() *RemoteEnvelope

func (*AckAndEnvelopeContainer) ProtoMessage 

func (*AckAndEnvelopeContainer) ProtoMessage()

func (*AckAndEnvelopeContainer) ProtoReflect 

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

func (*AckAndEnvelopeContainer) Reset 

func (x *AckAndEnvelopeContainer) Reset()

func (*AckAndEnvelopeContainer) String 

func (x *AckAndEnvelopeContainer) String() string

type AcknowledgementInfo 

type AcknowledgementInfo struct {
	CumulativeAck *uint64  `protobuf:"fixed64,1,req,name=cumulativeAck" json:"cumulativeAck,omitempty"`
	Nacks         []uint64 `protobuf:"fixed64,2,rep,name=nacks" json:"nacks,omitempty"`
	// contains filtered or unexported fields
}

func (*AcknowledgementInfo) Descriptor deprecated 

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

Deprecated: Use AcknowledgementInfo.ProtoReflect.Descriptor instead.

func (*AcknowledgementInfo) GetCumulativeAck 

func (x *AcknowledgementInfo) GetCumulativeAck() uint64

func (*AcknowledgementInfo) GetNacks 

func (x *AcknowledgementInfo) GetNacks() []uint64

func (*AcknowledgementInfo) ProtoMessage 

func (*AcknowledgementInfo) ProtoMessage()

func (*AcknowledgementInfo) ProtoReflect 

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

func (*AcknowledgementInfo) Reset 

func (x *AcknowledgementInfo) Reset()

func (*AcknowledgementInfo) String 

func (x *AcknowledgementInfo) String() string

type ActorIdentity 

type ActorIdentity struct {
	CorrelationId *Payload  `protobuf:"bytes,1,req,name=correlationId" json:"correlationId,omitempty"`
	Ref           *ActorRef `protobuf:"bytes,2,opt,name=ref" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*ActorIdentity) Descriptor deprecated 

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

Deprecated: Use ActorIdentity.ProtoReflect.Descriptor instead.

func (*ActorIdentity) GetCorrelationId 

func (x *ActorIdentity) GetCorrelationId() *Payload

func (*ActorIdentity) GetRef 

func (x *ActorIdentity) GetRef() *ActorRef

func (*ActorIdentity) ProtoMessage 

func (*ActorIdentity) ProtoMessage()

func (*ActorIdentity) ProtoReflect 

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

func (*ActorIdentity) Reset 

func (x *ActorIdentity) Reset()

func (*ActorIdentity) String 

func (x *ActorIdentity) String() string

type ActorInitializationException 

type ActorInitializationException struct {
	Actor   *ActorRef `protobuf:"bytes,1,opt,name=actor" json:"actor,omitempty"`
	Message *string   `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
	Cause   *Payload  `protobuf:"bytes,3,req,name=cause" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

func (*ActorInitializationException) Descriptor deprecated 

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

Deprecated: Use ActorInitializationException.ProtoReflect.Descriptor instead.

func (*ActorInitializationException) GetActor 

func (x *ActorInitializationException) GetActor() *ActorRef

func (*ActorInitializationException) GetCause 

func (x *ActorInitializationException) GetCause() *Payload

func (*ActorInitializationException) GetMessage 

func (x *ActorInitializationException) GetMessage() string

func (*ActorInitializationException) ProtoMessage 

func (*ActorInitializationException) ProtoMessage()

func (*ActorInitializationException) ProtoReflect 

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

func (*ActorInitializationException) Reset 

func (x *ActorInitializationException) Reset()

func (*ActorInitializationException) String 

func (x *ActorInitializationException) String() string

type ActorRef 

type ActorRef struct {
	Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*ActorRef) Descriptor deprecated 

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

Deprecated: Use ActorRef.ProtoReflect.Descriptor instead.

func (*ActorRef) GetPath 

func (x *ActorRef) GetPath() string

func (*ActorRef) ProtoMessage 

func (*ActorRef) ProtoMessage()

func (*ActorRef) ProtoReflect 

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

func (*ActorRef) Reset 

func (x *ActorRef) Reset()

func (*ActorRef) String 

func (x *ActorRef) String() string

type ActorRefData 

type ActorRefData struct {
	Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	// contains filtered or unexported fields
}

* Defines a remote ActorRef that "remembers" and uses its original Actor instance on the original node.

func (*ActorRefData) Descriptor deprecated 

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

Deprecated: Use ActorRefData.ProtoReflect.Descriptor instead.

func (*ActorRefData) GetPath 

func (x *ActorRefData) GetPath() string

func (*ActorRefData) ProtoMessage 

func (*ActorRefData) ProtoMessage()

func (*ActorRefData) ProtoReflect 

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

func (*ActorRefData) Reset 

func (x *ActorRefData) Reset()

func (*ActorRefData) String 

func (x *ActorRefData) String() string

type Address 

type Address struct {
	Protocol *string `protobuf:"bytes,1,req,name=protocol" json:"protocol,omitempty"`
	System   *string `protobuf:"bytes,2,req,name=system" json:"system,omitempty"`
	Hostname *string `protobuf:"bytes,3,req,name=hostname" json:"hostname,omitempty"`
	Port     *uint32 `protobuf:"varint,4,req,name=port" json:"port,omitempty"`
	// contains filtered or unexported fields
}

* Defines a remote address.

func (*Address) Descriptor deprecated 

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

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetHostname 

func (x *Address) GetHostname() string

func (*Address) GetPort 

func (x *Address) GetPort() uint32

func (*Address) GetProtocol 

func (x *Address) GetProtocol() string

func (*Address) GetSystem 

func (x *Address) GetSystem() string

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 AddressData 

type AddressData struct {
	System   *string `protobuf:"bytes,1,req,name=system" json:"system,omitempty"`
	Hostname *string `protobuf:"bytes,2,req,name=hostname" json:"hostname,omitempty"`
	Port     *uint32 `protobuf:"varint,3,req,name=port" json:"port,omitempty"`
	Protocol *string `protobuf:"bytes,4,opt,name=protocol" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

* Defines a remote address.

func (*AddressData) Descriptor deprecated 

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

Deprecated: Use AddressData.ProtoReflect.Descriptor instead.

func (*AddressData) GetHostname 

func (x *AddressData) GetHostname() string

func (*AddressData) GetPort 

func (x *AddressData) GetPort() uint32

func (*AddressData) GetProtocol 

func (x *AddressData) GetProtocol() string

func (*AddressData) GetSystem 

func (x *AddressData) GetSystem() string

func (*AddressData) ProtoMessage 

func (*AddressData) ProtoMessage()

func (*AddressData) ProtoReflect 

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

func (*AddressData) Reset 

func (x *AddressData) Reset()

func (*AddressData) String 

func (x *AddressData) String() string

type AkkaControlMessage 

type AkkaControlMessage struct {
	CommandType   *CommandType       `protobuf:"varint,1,req,name=commandType,enum=CommandType" json:"commandType,omitempty"`
	HandshakeInfo *AkkaHandshakeInfo `protobuf:"bytes,2,opt,name=handshakeInfo" json:"handshakeInfo,omitempty"`
	// contains filtered or unexported fields
}

* Defines some control messages for the remoting

func (*AkkaControlMessage) Descriptor deprecated 

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

Deprecated: Use AkkaControlMessage.ProtoReflect.Descriptor instead.

func (*AkkaControlMessage) GetCommandType 

func (x *AkkaControlMessage) GetCommandType() CommandType

func (*AkkaControlMessage) GetHandshakeInfo 

func (x *AkkaControlMessage) GetHandshakeInfo() *AkkaHandshakeInfo

func (*AkkaControlMessage) ProtoMessage 

func (*AkkaControlMessage) ProtoMessage()

func (*AkkaControlMessage) ProtoReflect 

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

func (*AkkaControlMessage) Reset 

func (x *AkkaControlMessage) Reset()

func (*AkkaControlMessage) String 

func (x *AkkaControlMessage) String() string

type AkkaHandshakeInfo 

type AkkaHandshakeInfo struct {
	Origin *AddressData `protobuf:"bytes,1,req,name=origin" json:"origin,omitempty"`
	Uid    *uint64      `protobuf:"fixed64,2,req,name=uid" json:"uid,omitempty"`
	Cookie *string      `protobuf:"bytes,3,opt,name=cookie" json:"cookie,omitempty"`
	// contains filtered or unexported fields
}

func (*AkkaHandshakeInfo) Descriptor deprecated 

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

Deprecated: Use AkkaHandshakeInfo.ProtoReflect.Descriptor instead.

func (*AkkaHandshakeInfo) GetCookie 

func (x *AkkaHandshakeInfo) GetCookie() string

func (*AkkaHandshakeInfo) GetOrigin 

func (x *AkkaHandshakeInfo) GetOrigin() *AddressData

func (*AkkaHandshakeInfo) GetUid 

func (x *AkkaHandshakeInfo) GetUid() uint64

func (*AkkaHandshakeInfo) ProtoMessage 

func (*AkkaHandshakeInfo) ProtoMessage()

func (*AkkaHandshakeInfo) ProtoReflect 

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

func (*AkkaHandshakeInfo) Reset 

func (x *AkkaHandshakeInfo) Reset()

func (*AkkaHandshakeInfo) String 

func (x *AkkaHandshakeInfo) String() string

type AkkaProtocolMessage 

type AkkaProtocolMessage struct {
	Payload     []byte              `protobuf:"bytes,1,opt,name=payload" json:"payload,omitempty"`
	Instruction *AkkaControlMessage `protobuf:"bytes,2,opt,name=instruction" json:"instruction,omitempty"`
	// contains filtered or unexported fields
}

* Message format of Akka Protocol. Message contains either a payload or an instruction.

func (*AkkaProtocolMessage) Descriptor deprecated 

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

Deprecated: Use AkkaProtocolMessage.ProtoReflect.Descriptor instead.

func (*AkkaProtocolMessage) GetInstruction 

func (x *AkkaProtocolMessage) GetInstruction() *AkkaControlMessage

func (*AkkaProtocolMessage) GetPayload 

func (x *AkkaProtocolMessage) GetPayload() []byte

func (*AkkaProtocolMessage) ProtoMessage 

func (*AkkaProtocolMessage) ProtoMessage()

func (*AkkaProtocolMessage) ProtoReflect 

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

func (*AkkaProtocolMessage) Reset 

func (x *AkkaProtocolMessage) Reset()

func (*AkkaProtocolMessage) String 

func (x *AkkaProtocolMessage) String() string

type ArteryHeartbeatRsp 

type ArteryHeartbeatRsp struct {
	Uid *uint64 `protobuf:"varint,1,req,name=uid" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

RemoteWatcher.ArteryHeartbeat is empty array RemoteWatcher.ArteryHeartbeatRsp

func (*ArteryHeartbeatRsp) Descriptor deprecated 

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

Deprecated: Use ArteryHeartbeatRsp.ProtoReflect.Descriptor instead.

func (*ArteryHeartbeatRsp) GetUid 

func (x *ArteryHeartbeatRsp) GetUid() uint64

func (*ArteryHeartbeatRsp) ProtoMessage 

func (*ArteryHeartbeatRsp) ProtoMessage()

func (*ArteryHeartbeatRsp) ProtoReflect 

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

func (*ArteryHeartbeatRsp) Reset 

func (x *ArteryHeartbeatRsp) Reset()

func (*ArteryHeartbeatRsp) String 

func (x *ArteryHeartbeatRsp) String() string

type CommandType 

type CommandType int32

* Defines the type of the AkkaControlMessage command type 

const (
	CommandType_ASSOCIATE                  CommandType = 1
	CommandType_DISASSOCIATE               CommandType = 2
	CommandType_HEARTBEAT                  CommandType = 3
	CommandType_DISASSOCIATE_SHUTTING_DOWN CommandType = 4 // Remote system is going down and will not accepts new connections
	CommandType_DISASSOCIATE_QUARANTINED   CommandType = 5 // Remote system refused the association since the current system is quarantined
)

func (CommandType) Descriptor 

func (CommandType) Descriptor() protoreflect.EnumDescriptor

func (CommandType) Enum 

func (x CommandType) Enum() *CommandType

func (CommandType) EnumDescriptor deprecated 

func (CommandType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CommandType.Descriptor instead.

func (CommandType) Number 

func (x CommandType) Number() protoreflect.EnumNumber

func (CommandType) String 

func (x CommandType) String() string

func (CommandType) Type 

func (CommandType) Type() protoreflect.EnumType

func (*CommandType) UnmarshalJSON deprecated 

func (x *CommandType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type CompressionTableAdvertisement 

type CompressionTableAdvertisement struct {
	From         *UniqueAddress `protobuf:"bytes,1,req,name=from" json:"from,omitempty"`
	OriginUid    *uint64        `protobuf:"varint,2,req,name=originUid" json:"originUid,omitempty"`
	TableVersion *uint32        `protobuf:"varint,3,req,name=tableVersion" json:"tableVersion,omitempty"`
	// actual Map is represented by separate sequences of keys and values,
	// relies on both sequences using the same order so that corresponding entries can be
	// associated again when deserializing
	Keys   []string `protobuf:"bytes,4,rep,name=keys" json:"keys,omitempty"`
	Values []uint32 `protobuf:"varint,5,rep,name=values" json:"values,omitempty"`
	// contains filtered or unexported fields
}

CompressionProtocol.ActorRefCompressionAdvertisement CompressionProtocol.ClassManifestCompressionAdvertisement

func (*CompressionTableAdvertisement) Descriptor deprecated 

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

Deprecated: Use CompressionTableAdvertisement.ProtoReflect.Descriptor instead.

func (*CompressionTableAdvertisement) GetFrom 

func (x *CompressionTableAdvertisement) GetFrom() *UniqueAddress

func (*CompressionTableAdvertisement) GetKeys 

func (x *CompressionTableAdvertisement) GetKeys() []string

func (*CompressionTableAdvertisement) GetOriginUid 

func (x *CompressionTableAdvertisement) GetOriginUid() uint64

func (*CompressionTableAdvertisement) GetTableVersion 

func (x *CompressionTableAdvertisement) GetTableVersion() uint32

func (*CompressionTableAdvertisement) GetValues 

func (x *CompressionTableAdvertisement) GetValues() []uint32

func (*CompressionTableAdvertisement) ProtoMessage 

func (*CompressionTableAdvertisement) ProtoMessage()

func (*CompressionTableAdvertisement) ProtoReflect 

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

func (*CompressionTableAdvertisement) Reset 

func (x *CompressionTableAdvertisement) Reset()

func (*CompressionTableAdvertisement) String 

func (x *CompressionTableAdvertisement) String() string

type CompressionTableAdvertisementAck 

type CompressionTableAdvertisementAck struct {
	From    *UniqueAddress `protobuf:"bytes,1,req,name=from" json:"from,omitempty"`
	Version *uint32        `protobuf:"varint,2,req,name=version" json:"version,omitempty"`
	// contains filtered or unexported fields
}

CompressionProtocol.ActorRefCompressionAdvertisementAck CompressionProtocol.ClassManifestCompressionAdvertisementAck

func (*CompressionTableAdvertisementAck) Descriptor deprecated 

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

Deprecated: Use CompressionTableAdvertisementAck.ProtoReflect.Descriptor instead.

func (*CompressionTableAdvertisementAck) GetFrom 

func (x *CompressionTableAdvertisementAck) GetFrom() *UniqueAddress

func (*CompressionTableAdvertisementAck) GetVersion 

func (x *CompressionTableAdvertisementAck) GetVersion() uint32

func (*CompressionTableAdvertisementAck) ProtoMessage 

func (*CompressionTableAdvertisementAck) ProtoMessage()

func (*CompressionTableAdvertisementAck) ProtoReflect 

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

func (*CompressionTableAdvertisementAck) Reset 

func (x *CompressionTableAdvertisementAck) Reset()

func (*CompressionTableAdvertisementAck) String 

func (x *CompressionTableAdvertisementAck) String() string

type DaemonMsgCreateData 

type DaemonMsgCreateData struct {
	Props      *PropsData    `protobuf:"bytes,1,req,name=props" json:"props,omitempty"`
	Deploy     *DeployData   `protobuf:"bytes,2,req,name=deploy" json:"deploy,omitempty"`
	Path       *string       `protobuf:"bytes,3,req,name=path" json:"path,omitempty"`
	Supervisor *ActorRefData `protobuf:"bytes,4,req,name=supervisor" json:"supervisor,omitempty"`
	// contains filtered or unexported fields
}

* Defines akka.remote.DaemonMsgCreate

func (*DaemonMsgCreateData) Descriptor deprecated 

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

Deprecated: Use DaemonMsgCreateData.ProtoReflect.Descriptor instead.

func (*DaemonMsgCreateData) GetDeploy 

func (x *DaemonMsgCreateData) GetDeploy() *DeployData

func (*DaemonMsgCreateData) GetPath 

func (x *DaemonMsgCreateData) GetPath() string

func (*DaemonMsgCreateData) GetProps 

func (x *DaemonMsgCreateData) GetProps() *PropsData

func (*DaemonMsgCreateData) GetSupervisor 

func (x *DaemonMsgCreateData) GetSupervisor() *ActorRefData

func (*DaemonMsgCreateData) ProtoMessage 

func (*DaemonMsgCreateData) ProtoMessage()

func (*DaemonMsgCreateData) ProtoReflect 

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

func (*DaemonMsgCreateData) Reset 

func (x *DaemonMsgCreateData) Reset()

func (*DaemonMsgCreateData) String 

func (x *DaemonMsgCreateData) String() string

type DeathWatchNotificationData 

type DeathWatchNotificationData struct {
	Actor              *ActorRef `protobuf:"bytes,1,req,name=actor" json:"actor,omitempty"`
	ExistenceConfirmed *bool     `protobuf:"varint,2,req,name=existenceConfirmed" json:"existenceConfirmed,omitempty"`
	AddressTerminated  *bool     `protobuf:"varint,3,req,name=addressTerminated" json:"addressTerminated,omitempty"`
	// contains filtered or unexported fields
}

func (*DeathWatchNotificationData) Descriptor deprecated 

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

Deprecated: Use DeathWatchNotificationData.ProtoReflect.Descriptor instead.

func (*DeathWatchNotificationData) GetActor 

func (x *DeathWatchNotificationData) GetActor() *ActorRef

func (*DeathWatchNotificationData) GetAddressTerminated 

func (x *DeathWatchNotificationData) GetAddressTerminated() bool

func (*DeathWatchNotificationData) GetExistenceConfirmed 

func (x *DeathWatchNotificationData) GetExistenceConfirmed() bool

func (*DeathWatchNotificationData) ProtoMessage 

func (*DeathWatchNotificationData) ProtoMessage()

func (*DeathWatchNotificationData) ProtoReflect 

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

func (*DeathWatchNotificationData) Reset 

func (x *DeathWatchNotificationData) Reset()

func (*DeathWatchNotificationData) String 

func (x *DeathWatchNotificationData) String() string

type DefaultResizer 

type DefaultResizer struct {
	LowerBound        *uint32  `protobuf:"varint,1,req,name=lowerBound" json:"lowerBound,omitempty"`
	UpperBound        *uint32  `protobuf:"varint,2,req,name=upperBound" json:"upperBound,omitempty"`
	PressureThreshold *uint32  `protobuf:"varint,3,req,name=pressureThreshold" json:"pressureThreshold,omitempty"`
	RampupRate        *float64 `protobuf:"fixed64,4,req,name=rampupRate" json:"rampupRate,omitempty"`
	BackoffThreshold  *float64 `protobuf:"fixed64,5,req,name=backoffThreshold" json:"backoffThreshold,omitempty"`
	BackoffRate       *float64 `protobuf:"fixed64,6,req,name=backoffRate" json:"backoffRate,omitempty"`
	MessagesPerResize *uint32  `protobuf:"varint,7,req,name=messagesPerResize" json:"messagesPerResize,omitempty"`
	// contains filtered or unexported fields
}

func (*DefaultResizer) Descriptor deprecated 

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

Deprecated: Use DefaultResizer.ProtoReflect.Descriptor instead.

func (*DefaultResizer) GetBackoffRate 

func (x *DefaultResizer) GetBackoffRate() float64

func (*DefaultResizer) GetBackoffThreshold 

func (x *DefaultResizer) GetBackoffThreshold() float64

func (*DefaultResizer) GetLowerBound 

func (x *DefaultResizer) GetLowerBound() uint32

func (*DefaultResizer) GetMessagesPerResize 

func (x *DefaultResizer) GetMessagesPerResize() uint32

func (*DefaultResizer) GetPressureThreshold 

func (x *DefaultResizer) GetPressureThreshold() uint32

func (*DefaultResizer) GetRampupRate 

func (x *DefaultResizer) GetRampupRate() float64

func (*DefaultResizer) GetUpperBound 

func (x *DefaultResizer) GetUpperBound() uint32

func (*DefaultResizer) ProtoMessage 

func (*DefaultResizer) ProtoMessage()

func (*DefaultResizer) ProtoReflect 

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

func (*DefaultResizer) Reset 

func (x *DefaultResizer) Reset()

func (*DefaultResizer) String 

func (x *DefaultResizer) String() string

type DeployData 

type DeployData struct {
	Path         *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Config       []byte  `protobuf:"bytes,2,opt,name=config" json:"config,omitempty"`
	RouterConfig []byte  `protobuf:"bytes,3,opt,name=routerConfig" json:"routerConfig,omitempty"`
	Scope        []byte  `protobuf:"bytes,4,opt,name=scope" json:"scope,omitempty"`
	Dispatcher   *string `protobuf:"bytes,5,opt,name=dispatcher" json:"dispatcher,omitempty"`
	// older wire protocol: hardcoded class used to look up serializer
	// newer wire protocol: serializer id and manifest available for each
	ScopeSerializerId        *int32  `protobuf:"varint,6,opt,name=scopeSerializerId" json:"scopeSerializerId,omitempty"`
	ScopeManifest            *string `protobuf:"bytes,7,opt,name=scopeManifest" json:"scopeManifest,omitempty"`
	ConfigSerializerId       *int32  `protobuf:"varint,8,opt,name=configSerializerId" json:"configSerializerId,omitempty"`
	ConfigManifest           *string `protobuf:"bytes,9,opt,name=configManifest" json:"configManifest,omitempty"`
	RouterConfigSerializerId *int32  `protobuf:"varint,10,opt,name=routerConfigSerializerId" json:"routerConfigSerializerId,omitempty"`
	RouterConfigManifest     *string `protobuf:"bytes,11,opt,name=routerConfigManifest" json:"routerConfigManifest,omitempty"`
	// contains filtered or unexported fields
}

* Serialization of akka.actor.Deploy

func (*DeployData) Descriptor deprecated 

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

Deprecated: Use DeployData.ProtoReflect.Descriptor instead.

func (*DeployData) GetConfig 

func (x *DeployData) GetConfig() []byte

func (*DeployData) GetConfigManifest 

func (x *DeployData) GetConfigManifest() string

func (*DeployData) GetConfigSerializerId 

func (x *DeployData) GetConfigSerializerId() int32

func (*DeployData) GetDispatcher 

func (x *DeployData) GetDispatcher() string

func (*DeployData) GetPath 

func (x *DeployData) GetPath() string

func (*DeployData) GetRouterConfig 

func (x *DeployData) GetRouterConfig() []byte

func (*DeployData) GetRouterConfigManifest 

func (x *DeployData) GetRouterConfigManifest() string

func (*DeployData) GetRouterConfigSerializerId 

func (x *DeployData) GetRouterConfigSerializerId() int32

func (*DeployData) GetScope 

func (x *DeployData) GetScope() []byte

func (*DeployData) GetScopeManifest 

func (x *DeployData) GetScopeManifest() string

func (*DeployData) GetScopeSerializerId 

func (x *DeployData) GetScopeSerializerId() int32

func (*DeployData) ProtoMessage 

func (*DeployData) ProtoMessage()

func (*DeployData) ProtoReflect 

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

func (*DeployData) Reset 

func (x *DeployData) Reset()

func (*DeployData) String 

func (x *DeployData) String() string

type FailedData 

type FailedData struct {
	Child *ActorRef `protobuf:"bytes,1,req,name=child" json:"child,omitempty"`
	Uid   *uint64   `protobuf:"varint,2,req,name=uid" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*FailedData) Descriptor deprecated 

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

Deprecated: Use FailedData.ProtoReflect.Descriptor instead.

func (*FailedData) GetChild 

func (x *FailedData) GetChild() *ActorRef

func (*FailedData) GetUid 

func (x *FailedData) GetUid() uint64

func (*FailedData) ProtoMessage 

func (*FailedData) ProtoMessage()

func (*FailedData) ProtoReflect 

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

func (*FailedData) Reset 

func (x *FailedData) Reset()

func (*FailedData) String 

func (x *FailedData) String() string

type FiniteDuration 

type FiniteDuration struct {
	Value *int64    `protobuf:"varint,1,req,name=value" json:"value,omitempty"`
	Unit  *TimeUnit `protobuf:"varint,2,req,name=unit,enum=TimeUnit" json:"unit,omitempty"`
	// contains filtered or unexported fields
}

func (*FiniteDuration) Descriptor deprecated 

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

Deprecated: Use FiniteDuration.ProtoReflect.Descriptor instead.

func (*FiniteDuration) GetUnit 

func (x *FiniteDuration) GetUnit() TimeUnit

func (*FiniteDuration) GetValue 

func (x *FiniteDuration) GetValue() int64

func (*FiniteDuration) ProtoMessage 

func (*FiniteDuration) ProtoMessage()

func (*FiniteDuration) ProtoReflect 

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

func (*FiniteDuration) Reset 

func (x *FiniteDuration) Reset()

func (*FiniteDuration) String 

func (x *FiniteDuration) String() string

type FromConfig 

type FromConfig struct {
	Resizer          *Payload `protobuf:"bytes,1,opt,name=resizer" json:"resizer,omitempty"`
	RouterDispatcher *string  `protobuf:"bytes,2,opt,name=routerDispatcher" json:"routerDispatcher,omitempty"`
	// contains filtered or unexported fields
}

func (*FromConfig) Descriptor deprecated 

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

Deprecated: Use FromConfig.ProtoReflect.Descriptor instead.

func (*FromConfig) GetResizer 

func (x *FromConfig) GetResizer() *Payload

func (*FromConfig) GetRouterDispatcher 

func (x *FromConfig) GetRouterDispatcher() string

func (*FromConfig) ProtoMessage 

func (*FromConfig) ProtoMessage()

func (*FromConfig) ProtoReflect 

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

func (*FromConfig) Reset 

func (x *FromConfig) Reset()

func (*FromConfig) String 

func (x *FromConfig) String() string

type GenericRoutingPool 

type GenericRoutingPool struct {
	NrOfInstances     *uint32  `protobuf:"varint,1,req,name=nrOfInstances" json:"nrOfInstances,omitempty"`
	RouterDispatcher  *string  `protobuf:"bytes,2,opt,name=routerDispatcher" json:"routerDispatcher,omitempty"`
	UsePoolDispatcher *bool    `protobuf:"varint,3,req,name=usePoolDispatcher" json:"usePoolDispatcher,omitempty"`
	Resizer           *Payload `protobuf:"bytes,4,opt,name=resizer" json:"resizer,omitempty"`
	// contains filtered or unexported fields
}

func (*GenericRoutingPool) Descriptor deprecated 

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

Deprecated: Use GenericRoutingPool.ProtoReflect.Descriptor instead.

func (*GenericRoutingPool) GetNrOfInstances 

func (x *GenericRoutingPool) GetNrOfInstances() uint32

func (*GenericRoutingPool) GetResizer 

func (x *GenericRoutingPool) GetResizer() *Payload

func (*GenericRoutingPool) GetRouterDispatcher 

func (x *GenericRoutingPool) GetRouterDispatcher() string

func (*GenericRoutingPool) GetUsePoolDispatcher 

func (x *GenericRoutingPool) GetUsePoolDispatcher() bool

func (*GenericRoutingPool) ProtoMessage 

func (*GenericRoutingPool) ProtoMessage()

func (*GenericRoutingPool) ProtoReflect 

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

func (*GenericRoutingPool) Reset 

func (x *GenericRoutingPool) Reset()

func (*GenericRoutingPool) String 

func (x *GenericRoutingPool) String() string

type HandshakeReq 

type HandshakeReq struct {
	From *UniqueAddress `protobuf:"bytes,1,req,name=from" json:"from,omitempty"`
	To   *Address       `protobuf:"bytes,2,req,name=to" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakeReq) Descriptor deprecated 

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

Deprecated: Use HandshakeReq.ProtoReflect.Descriptor instead.

func (*HandshakeReq) GetFrom 

func (x *HandshakeReq) GetFrom() *UniqueAddress

func (*HandshakeReq) GetTo 

func (x *HandshakeReq) GetTo() *Address

func (*HandshakeReq) ProtoMessage 

func (*HandshakeReq) ProtoMessage()

func (*HandshakeReq) ProtoReflect 

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

func (*HandshakeReq) Reset 

func (x *HandshakeReq) Reset()

func (*HandshakeReq) String 

func (x *HandshakeReq) String() string

type Identify 

type Identify struct {
	MessageId *Payload `protobuf:"bytes,1,req,name=messageId" json:"messageId,omitempty"`
	// contains filtered or unexported fields
}

func (*Identify) Descriptor deprecated 

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

Deprecated: Use Identify.ProtoReflect.Descriptor instead.

func (*Identify) GetMessageId 

func (x *Identify) GetMessageId() *Payload

func (*Identify) ProtoMessage 

func (*Identify) ProtoMessage()

func (*Identify) ProtoReflect 

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

func (*Identify) Reset 

func (x *Identify) Reset()

func (*Identify) String 

func (x *Identify) String() string

type MessageWithAddress 

type MessageWithAddress struct {
	Address *UniqueAddress `protobuf:"bytes,1,req,name=address" json:"address,omitempty"`
	// contains filtered or unexported fields
}

Generic message declaration that is used for all types of message that (currently) have a single address field. A message that needs to changed later can be cloned from this one and then adapted. ActorSystemTerminating ActorSystemTerminating.Ack OutboundHandshake.HandshakeRsp

func (*MessageWithAddress) Descriptor deprecated 

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

Deprecated: Use MessageWithAddress.ProtoReflect.Descriptor instead.

func (*MessageWithAddress) GetAddress 

func (x *MessageWithAddress) GetAddress() *UniqueAddress

func (*MessageWithAddress) ProtoMessage 

func (*MessageWithAddress) ProtoMessage()

func (*MessageWithAddress) ProtoReflect 

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

func (*MessageWithAddress) Reset 

func (x *MessageWithAddress) Reset()

func (*MessageWithAddress) String 

func (x *MessageWithAddress) String() string

type Option 

type Option struct {
	Value *Payload `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Option) Descriptor deprecated 

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

Deprecated: Use Option.ProtoReflect.Descriptor instead.

func (*Option) GetValue 

func (x *Option) GetValue() *Payload

func (*Option) ProtoMessage 

func (*Option) ProtoMessage()

func (*Option) ProtoReflect 

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

func (*Option) Reset 

func (x *Option) Reset()

func (*Option) String 

func (x *Option) String() string

type PatternType 

type PatternType int32
const (
	PatternType_PARENT        PatternType = 0
	PatternType_CHILD_NAME    PatternType = 1
	PatternType_CHILD_PATTERN PatternType = 2
)

func (PatternType) Descriptor 

func (PatternType) Descriptor() protoreflect.EnumDescriptor

func (PatternType) Enum 

func (x PatternType) Enum() *PatternType

func (PatternType) EnumDescriptor deprecated 

func (PatternType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PatternType.Descriptor instead.

func (PatternType) Number 

func (x PatternType) Number() protoreflect.EnumNumber

func (PatternType) String 

func (x PatternType) String() string

func (PatternType) Type 

func (PatternType) Type() protoreflect.EnumType

func (*PatternType) UnmarshalJSON deprecated 

func (x *PatternType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Payload 

type Payload struct {
	EnclosedMessage []byte `protobuf:"bytes,1,req,name=enclosedMessage" json:"enclosedMessage,omitempty"`
	SerializerId    *int32 `protobuf:"varint,2,req,name=serializerId" json:"serializerId,omitempty"`
	MessageManifest []byte `protobuf:"bytes,4,opt,name=messageManifest" json:"messageManifest,omitempty"`
	// contains filtered or unexported fields
}

func (*Payload) Descriptor deprecated 

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetEnclosedMessage 

func (x *Payload) GetEnclosedMessage() []byte

func (*Payload) GetMessageManifest 

func (x *Payload) GetMessageManifest() []byte

func (*Payload) GetSerializerId 

func (x *Payload) GetSerializerId() int32

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect 

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

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) String 

func (x *Payload) String() string

type PropsData 

type PropsData struct {
	Deploy *DeployData `protobuf:"bytes,2,req,name=deploy" json:"deploy,omitempty"`
	Clazz  *string     `protobuf:"bytes,3,req,name=clazz" json:"clazz,omitempty"`
	Args   [][]byte    `protobuf:"bytes,4,rep,name=args" json:"args,omitempty"`
	// serialized props parameters
	// older wire protocol: contains class name for each arg
	// newer wire protocol: contains string manifest for each arg
	Manifests []string `protobuf:"bytes,5,rep,name=manifests" json:"manifests,omitempty"`
	// newer wire protocol: serializer id for each arg
	SerializerIds []int32 `protobuf:"varint,6,rep,name=serializerIds" json:"serializerIds,omitempty"`
	// additionally a flag per position to indicate if it was
	// serialized with manifest or not
	HasManifest []bool `protobuf:"varint,7,rep,name=hasManifest" json:"hasManifest,omitempty"`
	// contains filtered or unexported fields
}

* Serialization of akka.actor.Props

func (*PropsData) Descriptor deprecated 

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

Deprecated: Use PropsData.ProtoReflect.Descriptor instead.

func (*PropsData) GetArgs 

func (x *PropsData) GetArgs() [][]byte

func (*PropsData) GetClazz 

func (x *PropsData) GetClazz() string

func (*PropsData) GetDeploy 

func (x *PropsData) GetDeploy() *DeployData

func (*PropsData) GetHasManifest 

func (x *PropsData) GetHasManifest() []bool

func (*PropsData) GetManifests 

func (x *PropsData) GetManifests() []string

func (*PropsData) GetSerializerIds 

func (x *PropsData) GetSerializerIds() []int32

func (*PropsData) ProtoMessage 

func (*PropsData) ProtoMessage()

func (*PropsData) ProtoReflect 

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

func (*PropsData) Reset 

func (x *PropsData) Reset()

func (*PropsData) String 

func (x *PropsData) String() string

type Quarantined 

type Quarantined struct {
	From *UniqueAddress `protobuf:"bytes,1,req,name=from" json:"from,omitempty"`
	To   *UniqueAddress `protobuf:"bytes,2,req,name=to" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*Quarantined) Descriptor deprecated 

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

Deprecated: Use Quarantined.ProtoReflect.Descriptor instead.

func (*Quarantined) GetFrom 

func (x *Quarantined) GetFrom() *UniqueAddress

func (*Quarantined) GetTo 

func (x *Quarantined) GetTo() *UniqueAddress

func (*Quarantined) ProtoMessage 

func (*Quarantined) ProtoMessage()

func (*Quarantined) ProtoReflect 

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

func (*Quarantined) Reset 

func (x *Quarantined) Reset()

func (*Quarantined) String 

func (x *Quarantined) String() string

type RemoteEnvelope 

type RemoteEnvelope struct {
	Recipient *ActorRefData      `protobuf:"bytes,1,req,name=recipient" json:"recipient,omitempty"`
	Message   *SerializedMessage `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
	Sender    *ActorRefData      `protobuf:"bytes,4,opt,name=sender" json:"sender,omitempty"`
	Seq       *uint64            `protobuf:"fixed64,5,opt,name=seq" json:"seq,omitempty"`
	// contains filtered or unexported fields
}

* Defines a remote message.

func (*RemoteEnvelope) Descriptor deprecated 

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

Deprecated: Use RemoteEnvelope.ProtoReflect.Descriptor instead.

func (*RemoteEnvelope) GetMessage 

func (x *RemoteEnvelope) GetMessage() *SerializedMessage

func (*RemoteEnvelope) GetRecipient 

func (x *RemoteEnvelope) GetRecipient() *ActorRefData

func (*RemoteEnvelope) GetSender 

func (x *RemoteEnvelope) GetSender() *ActorRefData

func (*RemoteEnvelope) GetSeq 

func (x *RemoteEnvelope) GetSeq() uint64

func (*RemoteEnvelope) ProtoMessage 

func (*RemoteEnvelope) ProtoMessage()

func (*RemoteEnvelope) ProtoReflect 

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

func (*RemoteEnvelope) Reset 

func (x *RemoteEnvelope) Reset()

func (*RemoteEnvelope) String 

func (x *RemoteEnvelope) String() string

type RemoteRouterConfig 

type RemoteRouterConfig struct {
	Local *Payload       `protobuf:"bytes,1,req,name=local" json:"local,omitempty"`
	Nodes []*AddressData `protobuf:"bytes,2,rep,name=nodes" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteRouterConfig) Descriptor deprecated 

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

Deprecated: Use RemoteRouterConfig.ProtoReflect.Descriptor instead.

func (*RemoteRouterConfig) GetLocal 

func (x *RemoteRouterConfig) GetLocal() *Payload

func (*RemoteRouterConfig) GetNodes 

func (x *RemoteRouterConfig) GetNodes() []*AddressData

func (*RemoteRouterConfig) ProtoMessage 

func (*RemoteRouterConfig) ProtoMessage()

func (*RemoteRouterConfig) ProtoReflect 

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

func (*RemoteRouterConfig) Reset 

func (x *RemoteRouterConfig) Reset()

func (*RemoteRouterConfig) String 

func (x *RemoteRouterConfig) String() string

type RemoteScope 

type RemoteScope struct {
	Node *AddressData `protobuf:"bytes,1,req,name=node" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteScope) Descriptor deprecated 

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

Deprecated: Use RemoteScope.ProtoReflect.Descriptor instead.

func (*RemoteScope) GetNode 

func (x *RemoteScope) GetNode() *AddressData

func (*RemoteScope) ProtoMessage 

func (*RemoteScope) ProtoMessage()

func (*RemoteScope) ProtoReflect 

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

func (*RemoteScope) Reset 

func (x *RemoteScope) Reset()

func (*RemoteScope) String 

func (x *RemoteScope) String() string

type ScatterGatherPool 

type ScatterGatherPool struct {
	Generic *GenericRoutingPool `protobuf:"bytes,1,req,name=generic" json:"generic,omitempty"`
	Within  *FiniteDuration     `protobuf:"bytes,2,req,name=within" json:"within,omitempty"`
	// contains filtered or unexported fields
}

func (*ScatterGatherPool) Descriptor deprecated 

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

Deprecated: Use ScatterGatherPool.ProtoReflect.Descriptor instead.

func (*ScatterGatherPool) GetGeneric 

func (x *ScatterGatherPool) GetGeneric() *GenericRoutingPool

func (*ScatterGatherPool) GetWithin 

func (x *ScatterGatherPool) GetWithin() *FiniteDuration

func (*ScatterGatherPool) ProtoMessage 

func (*ScatterGatherPool) ProtoMessage()

func (*ScatterGatherPool) ProtoReflect 

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

func (*ScatterGatherPool) Reset 

func (x *ScatterGatherPool) Reset()

func (*ScatterGatherPool) String 

func (x *ScatterGatherPool) String() string

type Selection 

type Selection struct {
	Type    *PatternType `protobuf:"varint,1,req,name=type,enum=PatternType" json:"type,omitempty"`
	Matcher *string      `protobuf:"bytes,2,opt,name=matcher" json:"matcher,omitempty"`
	// contains filtered or unexported fields
}

func (*Selection) Descriptor deprecated 

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

Deprecated: Use Selection.ProtoReflect.Descriptor instead.

func (*Selection) GetMatcher 

func (x *Selection) GetMatcher() string

func (*Selection) GetType 

func (x *Selection) GetType() PatternType

func (*Selection) ProtoMessage 

func (*Selection) ProtoMessage()

func (*Selection) ProtoReflect 

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

func (*Selection) Reset 

func (x *Selection) Reset()

func (*Selection) String 

func (x *Selection) String() string

type SelectionEnvelope 

type SelectionEnvelope struct {
	EnclosedMessage []byte       `protobuf:"bytes,1,req,name=enclosedMessage" json:"enclosedMessage,omitempty"`
	SerializerId    *int32       `protobuf:"varint,2,req,name=serializerId" json:"serializerId,omitempty"`
	Pattern         []*Selection `protobuf:"bytes,3,rep,name=pattern" json:"pattern,omitempty"`
	MessageManifest []byte       `protobuf:"bytes,4,opt,name=messageManifest" json:"messageManifest,omitempty"`
	WildcardFanOut  *bool        `protobuf:"varint,5,opt,name=wildcardFanOut" json:"wildcardFanOut,omitempty"` // optional for pre 2.3.4 compatibility
	// contains filtered or unexported fields
}

func (*SelectionEnvelope) Descriptor deprecated 

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

Deprecated: Use SelectionEnvelope.ProtoReflect.Descriptor instead.

func (*SelectionEnvelope) GetEnclosedMessage 

func (x *SelectionEnvelope) GetEnclosedMessage() []byte

func (*SelectionEnvelope) GetMessageManifest 

func (x *SelectionEnvelope) GetMessageManifest() []byte

func (*SelectionEnvelope) GetPattern 

func (x *SelectionEnvelope) GetPattern() []*Selection

func (*SelectionEnvelope) GetSerializerId 

func (x *SelectionEnvelope) GetSerializerId() int32

func (*SelectionEnvelope) GetWildcardFanOut 

func (x *SelectionEnvelope) GetWildcardFanOut() bool

func (*SelectionEnvelope) ProtoMessage 

func (*SelectionEnvelope) ProtoMessage()

func (*SelectionEnvelope) ProtoReflect 

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

func (*SelectionEnvelope) Reset 

func (x *SelectionEnvelope) Reset()

func (*SelectionEnvelope) String 

func (x *SelectionEnvelope) String() string

type SerializedMessage 

type SerializedMessage struct {
	Message         []byte `protobuf:"bytes,1,req,name=message" json:"message,omitempty"`
	SerializerId    *int32 `protobuf:"varint,2,req,name=serializerId" json:"serializerId,omitempty"`
	MessageManifest []byte `protobuf:"bytes,3,opt,name=messageManifest" json:"messageManifest,omitempty"`
	// contains filtered or unexported fields
}

* Defines a message.

func (*SerializedMessage) Descriptor deprecated 

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

Deprecated: Use SerializedMessage.ProtoReflect.Descriptor instead.

func (*SerializedMessage) GetMessage 

func (x *SerializedMessage) GetMessage() []byte

func (*SerializedMessage) GetMessageManifest 

func (x *SerializedMessage) GetMessageManifest() []byte

func (*SerializedMessage) GetSerializerId 

func (x *SerializedMessage) GetSerializerId() int32

func (*SerializedMessage) ProtoMessage 

func (*SerializedMessage) ProtoMessage()

func (*SerializedMessage) ProtoReflect 

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

func (*SerializedMessage) Reset 

func (x *SerializedMessage) Reset()

func (*SerializedMessage) String 

func (x *SerializedMessage) String() string

type StackTraceElement 

type StackTraceElement struct {
	ClassName  *string `protobuf:"bytes,1,req,name=className" json:"className,omitempty"`
	MethodName *string `protobuf:"bytes,2,req,name=methodName" json:"methodName,omitempty"`
	FileName   *string `protobuf:"bytes,3,req,name=fileName" json:"fileName,omitempty"`
	LineNumber *int32  `protobuf:"varint,4,req,name=lineNumber" json:"lineNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*StackTraceElement) Descriptor deprecated 

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

Deprecated: Use StackTraceElement.ProtoReflect.Descriptor instead.

func (*StackTraceElement) GetClassName 

func (x *StackTraceElement) GetClassName() string

func (*StackTraceElement) GetFileName 

func (x *StackTraceElement) GetFileName() string

func (*StackTraceElement) GetLineNumber 

func (x *StackTraceElement) GetLineNumber() int32

func (*StackTraceElement) GetMethodName 

func (x *StackTraceElement) GetMethodName() string

func (*StackTraceElement) ProtoMessage 

func (*StackTraceElement) ProtoMessage()

func (*StackTraceElement) ProtoReflect 

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

func (*StackTraceElement) Reset 

func (x *StackTraceElement) Reset()

func (*StackTraceElement) String 

func (x *StackTraceElement) String() string

type SuperviseData 

type SuperviseData struct {
	Child *ActorRef `protobuf:"bytes,1,req,name=child" json:"child,omitempty"`
	Async *bool     `protobuf:"varint,2,req,name=async" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*SuperviseData) Descriptor deprecated 

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

Deprecated: Use SuperviseData.ProtoReflect.Descriptor instead.

func (*SuperviseData) GetAsync 

func (x *SuperviseData) GetAsync() bool

func (*SuperviseData) GetChild 

func (x *SuperviseData) GetChild() *ActorRef

func (*SuperviseData) ProtoMessage 

func (*SuperviseData) ProtoMessage()

func (*SuperviseData) ProtoReflect 

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

func (*SuperviseData) Reset 

func (x *SuperviseData) Reset()

func (*SuperviseData) String 

func (x *SuperviseData) String() string

type SystemMessage 

type SystemMessage struct {
	Type               *SystemMessage_Type         `protobuf:"varint,1,req,name=type,enum=SystemMessage_Type" json:"type,omitempty"`
	WatchData          *WatchData                  `protobuf:"bytes,2,opt,name=watchData" json:"watchData,omitempty"`
	CauseData          *Payload                    `protobuf:"bytes,3,opt,name=causeData" json:"causeData,omitempty"`
	SuperviseData      *SuperviseData              `protobuf:"bytes,5,opt,name=superviseData" json:"superviseData,omitempty"`
	FailedData         *FailedData                 `protobuf:"bytes,6,opt,name=failedData" json:"failedData,omitempty"`
	DwNotificationData *DeathWatchNotificationData `protobuf:"bytes,7,opt,name=dwNotificationData" json:"dwNotificationData,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemMessage) Descriptor deprecated 

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

Deprecated: Use SystemMessage.ProtoReflect.Descriptor instead.

func (*SystemMessage) GetCauseData 

func (x *SystemMessage) GetCauseData() *Payload

func (*SystemMessage) GetDwNotificationData 

func (x *SystemMessage) GetDwNotificationData() *DeathWatchNotificationData

func (*SystemMessage) GetFailedData 

func (x *SystemMessage) GetFailedData() *FailedData

func (*SystemMessage) GetSuperviseData 

func (x *SystemMessage) GetSuperviseData() *SuperviseData

func (*SystemMessage) GetType 

func (x *SystemMessage) GetType() SystemMessage_Type

func (*SystemMessage) GetWatchData 

func (x *SystemMessage) GetWatchData() *WatchData

func (*SystemMessage) ProtoMessage 

func (*SystemMessage) ProtoMessage()

func (*SystemMessage) ProtoReflect 

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

func (*SystemMessage) Reset 

func (x *SystemMessage) Reset()

func (*SystemMessage) String 

func (x *SystemMessage) String() string

type SystemMessageDeliveryAck 

type SystemMessageDeliveryAck struct {
	SeqNo *uint64        `protobuf:"varint,1,req,name=seqNo" json:"seqNo,omitempty"`
	From  *UniqueAddress `protobuf:"bytes,2,req,name=from" json:"from,omitempty"`
	// contains filtered or unexported fields
}

SystemMessageDelivery.Ack SystemMessageDelivery.Nack

func (*SystemMessageDeliveryAck) Descriptor deprecated 

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

Deprecated: Use SystemMessageDeliveryAck.ProtoReflect.Descriptor instead.

func (*SystemMessageDeliveryAck) GetFrom 

func (x *SystemMessageDeliveryAck) GetFrom() *UniqueAddress

func (*SystemMessageDeliveryAck) GetSeqNo 

func (x *SystemMessageDeliveryAck) GetSeqNo() uint64

func (*SystemMessageDeliveryAck) ProtoMessage 

func (*SystemMessageDeliveryAck) ProtoMessage()

func (*SystemMessageDeliveryAck) ProtoReflect 

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

func (*SystemMessageDeliveryAck) Reset 

func (x *SystemMessageDeliveryAck) Reset()

func (*SystemMessageDeliveryAck) String 

func (x *SystemMessageDeliveryAck) String() string

type SystemMessageEnvelope 

type SystemMessageEnvelope struct {
	Message         []byte         `protobuf:"bytes,1,req,name=message" json:"message,omitempty"`
	SerializerId    *int32         `protobuf:"varint,2,req,name=serializerId" json:"serializerId,omitempty"`
	MessageManifest []byte         `protobuf:"bytes,3,opt,name=messageManifest" json:"messageManifest,omitempty"`
	SeqNo           *uint64        `protobuf:"varint,4,req,name=seqNo" json:"seqNo,omitempty"`
	AckReplyTo      *UniqueAddress `protobuf:"bytes,5,req,name=ackReplyTo" json:"ackReplyTo,omitempty"`
	// contains filtered or unexported fields
}

SystemMessageDelivery.SystemMessageEnvelope

func (*SystemMessageEnvelope) Descriptor deprecated 

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

Deprecated: Use SystemMessageEnvelope.ProtoReflect.Descriptor instead.

func (*SystemMessageEnvelope) GetAckReplyTo 

func (x *SystemMessageEnvelope) GetAckReplyTo() *UniqueAddress

func (*SystemMessageEnvelope) GetMessage 

func (x *SystemMessageEnvelope) GetMessage() []byte

func (*SystemMessageEnvelope) GetMessageManifest 

func (x *SystemMessageEnvelope) GetMessageManifest() []byte

func (*SystemMessageEnvelope) GetSeqNo 

func (x *SystemMessageEnvelope) GetSeqNo() uint64

func (*SystemMessageEnvelope) GetSerializerId 

func (x *SystemMessageEnvelope) GetSerializerId() int32

func (*SystemMessageEnvelope) ProtoMessage 

func (*SystemMessageEnvelope) ProtoMessage()

func (*SystemMessageEnvelope) ProtoReflect 

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

func (*SystemMessageEnvelope) Reset 

func (x *SystemMessageEnvelope) Reset()

func (*SystemMessageEnvelope) String 

func (x *SystemMessageEnvelope) String() string

type SystemMessage_Type 

type SystemMessage_Type int32
const (
	SystemMessage_CREATE                  SystemMessage_Type = 0
	SystemMessage_RECREATE                SystemMessage_Type = 1
	SystemMessage_SUSPEND                 SystemMessage_Type = 2
	SystemMessage_RESUME                  SystemMessage_Type = 3
	SystemMessage_TERMINATE               SystemMessage_Type = 4
	SystemMessage_SUPERVISE               SystemMessage_Type = 5
	SystemMessage_WATCH                   SystemMessage_Type = 6
	SystemMessage_UNWATCH                 SystemMessage_Type = 7
	SystemMessage_FAILED                  SystemMessage_Type = 8
	SystemMessage_DEATHWATCH_NOTIFICATION SystemMessage_Type = 9
)

func (SystemMessage_Type) Descriptor 

func (SystemMessage_Type) Descriptor() protoreflect.EnumDescriptor

func (SystemMessage_Type) Enum 

func (x SystemMessage_Type) Enum() *SystemMessage_Type

func (SystemMessage_Type) EnumDescriptor deprecated 

func (SystemMessage_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use SystemMessage_Type.Descriptor instead.

func (SystemMessage_Type) Number 

func (x SystemMessage_Type) Number() protoreflect.EnumNumber

func (SystemMessage_Type) String 

func (x SystemMessage_Type) String() string

func (SystemMessage_Type) Type 

func (SystemMessage_Type) Type() protoreflect.EnumType

func (*SystemMessage_Type) UnmarshalJSON deprecated 

func (x *SystemMessage_Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TailChoppingPool 

type TailChoppingPool struct {
	Generic  *GenericRoutingPool `protobuf:"bytes,1,req,name=generic" json:"generic,omitempty"`
	Within   *FiniteDuration     `protobuf:"bytes,2,req,name=within" json:"within,omitempty"`
	Interval *FiniteDuration     `protobuf:"bytes,3,req,name=interval" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*TailChoppingPool) Descriptor deprecated 

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

Deprecated: Use TailChoppingPool.ProtoReflect.Descriptor instead.

func (*TailChoppingPool) GetGeneric 

func (x *TailChoppingPool) GetGeneric() *GenericRoutingPool

func (*TailChoppingPool) GetInterval 

func (x *TailChoppingPool) GetInterval() *FiniteDuration

func (*TailChoppingPool) GetWithin 

func (x *TailChoppingPool) GetWithin() *FiniteDuration

func (*TailChoppingPool) ProtoMessage 

func (*TailChoppingPool) ProtoMessage()

func (*TailChoppingPool) ProtoReflect 

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

func (*TailChoppingPool) Reset 

func (x *TailChoppingPool) Reset()

func (*TailChoppingPool) String 

func (x *TailChoppingPool) String() string

type Throwable 

type Throwable struct {
	ClassName  *string              `protobuf:"bytes,1,req,name=className" json:"className,omitempty"`
	Message    *string              `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	Cause      *Payload             `protobuf:"bytes,3,opt,name=cause" json:"cause,omitempty"`
	StackTrace []*StackTraceElement `protobuf:"bytes,4,rep,name=stackTrace" json:"stackTrace,omitempty"`
	// contains filtered or unexported fields
}

func (*Throwable) Descriptor deprecated 

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

Deprecated: Use Throwable.ProtoReflect.Descriptor instead.

func (*Throwable) GetCause 

func (x *Throwable) GetCause() *Payload

func (*Throwable) GetClassName 

func (x *Throwable) GetClassName() string

func (*Throwable) GetMessage 

func (x *Throwable) GetMessage() string

func (*Throwable) GetStackTrace 

func (x *Throwable) GetStackTrace() []*StackTraceElement

func (*Throwable) ProtoMessage 

func (*Throwable) ProtoMessage()

func (*Throwable) ProtoReflect 

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

func (*Throwable) Reset 

func (x *Throwable) Reset()

func (*Throwable) String 

func (x *Throwable) String() string

type ThrowableNotSerializable 

type ThrowableNotSerializable struct {
	Message           *string `protobuf:"bytes,1,req,name=message" json:"message,omitempty"`
	OriginalMessage   *string `protobuf:"bytes,2,req,name=originalMessage" json:"originalMessage,omitempty"`
	OriginalClassName *string `protobuf:"bytes,3,req,name=originalClassName" json:"originalClassName,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrowableNotSerializable) Descriptor deprecated 

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

Deprecated: Use ThrowableNotSerializable.ProtoReflect.Descriptor instead.

func (*ThrowableNotSerializable) GetMessage 

func (x *ThrowableNotSerializable) GetMessage() string

func (*ThrowableNotSerializable) GetOriginalClassName 

func (x *ThrowableNotSerializable) GetOriginalClassName() string

func (*ThrowableNotSerializable) GetOriginalMessage 

func (x *ThrowableNotSerializable) GetOriginalMessage() string

func (*ThrowableNotSerializable) ProtoMessage 

func (*ThrowableNotSerializable) ProtoMessage()

func (*ThrowableNotSerializable) ProtoReflect 

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

func (*ThrowableNotSerializable) Reset 

func (x *ThrowableNotSerializable) Reset()

func (*ThrowableNotSerializable) String 

func (x *ThrowableNotSerializable) String() string

type TimeUnit 

type TimeUnit int32

* java.util.concurrent.TimeUnit enum 

const (
	TimeUnit_NANOSECONDS  TimeUnit = 1
	TimeUnit_MICROSECONDS TimeUnit = 2
	TimeUnit_MILLISECONDS TimeUnit = 3
	TimeUnit_SECONDS      TimeUnit = 4
	TimeUnit_MINUTES      TimeUnit = 5
	TimeUnit_HOURS        TimeUnit = 6
	TimeUnit_DAYS         TimeUnit = 7
)

func (TimeUnit) Descriptor 

func (TimeUnit) Descriptor() protoreflect.EnumDescriptor

func (TimeUnit) Enum 

func (x TimeUnit) Enum() *TimeUnit

func (TimeUnit) EnumDescriptor deprecated 

func (TimeUnit) EnumDescriptor() ([]byte, []int)

Deprecated: Use TimeUnit.Descriptor instead.

func (TimeUnit) Number 

func (x TimeUnit) Number() protoreflect.EnumNumber

func (TimeUnit) String 

func (x TimeUnit) String() string

func (TimeUnit) Type 

func (TimeUnit) Type() protoreflect.EnumType

func (*TimeUnit) UnmarshalJSON deprecated 

func (x *TimeUnit) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type UniqueAddress 

type UniqueAddress struct {
	Address *Address `protobuf:"bytes,1,req,name=address" json:"address,omitempty"`
	Uid     *uint64  `protobuf:"varint,2,req,name=uid" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

* Defines a remote address with uid.

func (*UniqueAddress) Descriptor deprecated 

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

Deprecated: Use UniqueAddress.ProtoReflect.Descriptor instead.

func (*UniqueAddress) GetAddress 

func (x *UniqueAddress) GetAddress() *Address

func (*UniqueAddress) GetUid 

func (x *UniqueAddress) GetUid() uint64

func (*UniqueAddress) ProtoMessage 

func (*UniqueAddress) ProtoMessage()

func (*UniqueAddress) ProtoReflect 

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

func (*UniqueAddress) Reset 

func (x *UniqueAddress) Reset()

func (*UniqueAddress) String 

func (x *UniqueAddress) String() string

type WatchData 

type WatchData struct {
	Watchee *ActorRef `protobuf:"bytes,1,req,name=watchee" json:"watchee,omitempty"`
	Watcher *ActorRef `protobuf:"bytes,2,req,name=watcher" json:"watcher,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchData) Descriptor deprecated 

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

Deprecated: Use WatchData.ProtoReflect.Descriptor instead.

func (*WatchData) GetWatchee 

func (x *WatchData) GetWatchee() *ActorRef

func (*WatchData) GetWatcher 

func (x *WatchData) GetWatcher() *ActorRef

func (*WatchData) ProtoMessage 

func (*WatchData) ProtoMessage()

func (*WatchData) ProtoReflect 

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

func (*WatchData) Reset 

func (x *WatchData) Reset()

func (*WatchData) String 

func (x *WatchData) String() string

type WatcherHeartbeatResponse 

type WatcherHeartbeatResponse struct {
	Uid *uint64 `protobuf:"varint,1,req,name=uid" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*WatcherHeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use WatcherHeartbeatResponse.ProtoReflect.Descriptor instead.

func (*WatcherHeartbeatResponse) GetUid 

func (x *WatcherHeartbeatResponse) GetUid() uint64

func (*WatcherHeartbeatResponse) ProtoMessage 

func (*WatcherHeartbeatResponse) ProtoMessage()

func (*WatcherHeartbeatResponse) ProtoReflect 

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

func (*WatcherHeartbeatResponse) Reset 

func (x *WatcherHeartbeatResponse) Reset()

func (*WatcherHeartbeatResponse) String 

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