messages

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_messages_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AbyssMessageEvent 

type AbyssMessageEvent struct {
	Sender      *prc.ProcessId         `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Receiver    *prc.ProcessId         `protobuf:"bytes,2,opt,name=receiver,proto3" json:"receiver,omitempty"`
	Forward     *prc.ProcessId         `protobuf:"bytes,3,opt,name=forward,proto3" json:"forward,omitempty"`
	MessageType string                 `protobuf:"bytes,4,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	Data        []byte                 `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp   *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*AbyssMessageEvent) Descriptor deprecated 

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

Deprecated: Use AbyssMessageEvent.ProtoReflect.Descriptor instead.

func (*AbyssMessageEvent) GetData 

func (x *AbyssMessageEvent) GetData() []byte

func (*AbyssMessageEvent) GetForward 

func (x *AbyssMessageEvent) GetForward() *prc.ProcessId

func (*AbyssMessageEvent) GetMessageType 

func (x *AbyssMessageEvent) GetMessageType() string

func (*AbyssMessageEvent) GetReceiver 

func (x *AbyssMessageEvent) GetReceiver() *prc.ProcessId

func (*AbyssMessageEvent) GetSender 

func (x *AbyssMessageEvent) GetSender() *prc.ProcessId

func (*AbyssMessageEvent) GetTimestamp 

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

func (*AbyssMessageEvent) ProtoMessage 

func (*AbyssMessageEvent) ProtoMessage()

func (*AbyssMessageEvent) ProtoReflect 

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

func (*AbyssMessageEvent) Reset 

func (x *AbyssMessageEvent) Reset()

func (*AbyssMessageEvent) String 

func (x *AbyssMessageEvent) String() string

type LocalPublishRequest 

type LocalPublishRequest struct {
	Topic   string
	Message any
}

type PublishRequestBroadcast 

type PublishRequestBroadcast struct {
	MessageType string         `protobuf:"bytes,1,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	Data        []byte         `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Topic       string         `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Publisher   *prc.ProcessId `protobuf:"bytes,4,opt,name=publisher,proto3" json:"publisher,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequestBroadcast) Descriptor deprecated 

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

Deprecated: Use PublishRequestBroadcast.ProtoReflect.Descriptor instead.

func (*PublishRequestBroadcast) GetData 

func (x *PublishRequestBroadcast) GetData() []byte

func (*PublishRequestBroadcast) GetMessageType 

func (x *PublishRequestBroadcast) GetMessageType() string

func (*PublishRequestBroadcast) GetPublisher 

func (x *PublishRequestBroadcast) GetPublisher() *prc.ProcessId

func (*PublishRequestBroadcast) GetTopic 

func (x *PublishRequestBroadcast) GetTopic() string

func (*PublishRequestBroadcast) ProtoMessage 

func (*PublishRequestBroadcast) ProtoMessage()

func (*PublishRequestBroadcast) ProtoReflect 

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

func (*PublishRequestBroadcast) Reset 

func (x *PublishRequestBroadcast) Reset()

func (*PublishRequestBroadcast) String 

func (x *PublishRequestBroadcast) String() string

type SlowProcess 

type SlowProcess struct {
	Duration int64          `protobuf:"varint,1,opt,name=duration,proto3" json:"duration,omitempty"` // 耗时
	Pid      *prc.ProcessId `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`            // 耗时进程
	// contains filtered or unexported fields
}

func (*SlowProcess) Descriptor deprecated 

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

Deprecated: Use SlowProcess.ProtoReflect.Descriptor instead.

func (*SlowProcess) GetDuration 

func (x *SlowProcess) GetDuration() int64

func (*SlowProcess) GetPid 

func (x *SlowProcess) GetPid() *prc.ProcessId

func (*SlowProcess) ProtoMessage 

func (*SlowProcess) ProtoMessage()

func (*SlowProcess) ProtoReflect 

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

func (*SlowProcess) Reset 

func (x *SlowProcess) Reset()

func (*SlowProcess) String 

func (x *SlowProcess) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	Topic      string         `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Subscriber *prc.ProcessId `protobuf:"bytes,2,opt,name=subscriber,proto3" json:"subscriber,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetSubscriber 

func (x *SubscribeRequest) GetSubscriber() *prc.ProcessId

func (*SubscribeRequest) GetTopic 

func (x *SubscribeRequest) GetTopic() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type Subscription 

type Subscription struct {
	Topic      string         `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Id         uint64         `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Subscriber *prc.ProcessId `protobuf:"bytes,3,opt,name=subscriber,proto3" json:"subscriber,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetId 

func (x *Subscription) GetId() uint64

func (*Subscription) GetSubscriber 

func (x *Subscription) GetSubscriber() *prc.ProcessId

func (*Subscription) GetTopic 

func (x *Subscription) GetTopic() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

func (*Subscription) SubscriptionId 

func (s *Subscription) SubscriptionId() uint64

func (*Subscription) SubscriptionTopic 

func (s *Subscription) SubscriptionTopic() string

type Terminated 

type Terminated struct {
	TerminatedProcess *prc.ProcessId `protobuf:"bytes,1,opt,name=terminated_process,json=terminatedProcess,proto3" json:"terminated_process,omitempty"`
	// contains filtered or unexported fields
}

Terminated 当收到该消息时，说明 TerminatedActor 已经被终止，如果是自身，那么表示自身已被终止。

func (*Terminated) Descriptor deprecated 

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

Deprecated: Use Terminated.ProtoReflect.Descriptor instead.

func (*Terminated) GetTerminatedProcess 

func (x *Terminated) GetTerminatedProcess() *prc.ProcessId

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

type UnsubscribeRequest 

type UnsubscribeRequest struct {
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeRequest) Descriptor deprecated 

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

Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeRequest) GetSubscription 

func (x *UnsubscribeRequest) GetSubscription() *Subscription

func (*UnsubscribeRequest) ProtoMessage 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) ProtoReflect 

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

func (*UnsubscribeRequest) Reset 

func (x *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) String 

func (x *UnsubscribeRequest) String() string

type Unwatch 

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

func (*Unwatch) Descriptor deprecated 

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

Deprecated: Use Unwatch.ProtoReflect.Descriptor instead.

func (*Unwatch) ProtoMessage 

func (*Unwatch) ProtoMessage()

func (*Unwatch) ProtoReflect 

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

func (*Unwatch) Reset 

func (x *Unwatch) Reset()

func (*Unwatch) String 

func (x *Unwatch) String() string

type Watch 

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

func (*Watch) Descriptor deprecated 

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

Deprecated: Use Watch.ProtoReflect.Descriptor instead.

func (*Watch) ProtoMessage 

func (*Watch) ProtoMessage()

func (*Watch) ProtoReflect 

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

func (*Watch) Reset 

func (x *Watch) Reset()

func (*Watch) String 

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