actor_msg

package
v1.2.20 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2022 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthActorMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowActorMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupActorMsg = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ActorMessage 

type ActorMessage struct {
	SourceId   string            `protobuf:"bytes,1,opt,name=SourceId,proto3" json:"SourceId,omitempty"`
	TargetId   string            `protobuf:"bytes,2,opt,name=TargetId,proto3" json:"TargetId,omitempty"`
	RequestId  string            `protobuf:"bytes,3,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	MsgName    string            `protobuf:"bytes,4,opt,name=MsgName,proto3" json:"MsgName,omitempty"`
	Data       []byte            `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	MapCarrier map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func NewActorMessage added in v1.1.20 

func NewActorMessage() *ActorMessage

func (*ActorMessage) Descriptor 

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

func (*ActorMessage) Fill added in v1.2.0 

func (msg *ActorMessage) Fill(pi *tools.ProtoIndex) interface{}

func (*ActorMessage) Free 

func (msg *ActorMessage) Free()

func (*ActorMessage) GetData 

func (m *ActorMessage) GetData() []byte

func (*ActorMessage) GetMapCarrier added in v1.2.20 

func (m *ActorMessage) GetMapCarrier() map[string]string

func (*ActorMessage) GetMsgName 

func (m *ActorMessage) GetMsgName() string

func (*ActorMessage) GetRequestId 

func (m *ActorMessage) GetRequestId() string

func (*ActorMessage) GetSourceId 

func (m *ActorMessage) GetSourceId() string

func (*ActorMessage) GetTargetId 

func (m *ActorMessage) GetTargetId() string

func (*ActorMessage) LockFree added in v1.1.20 

func (msg *ActorMessage) LockFree()

func (*ActorMessage) Marshal 

func (m *ActorMessage) Marshal() (dAtA []byte, err error)

func (*ActorMessage) MarshalTo 

func (m *ActorMessage) MarshalTo(dAtA []byte) (int, error)

func (*ActorMessage) MarshalToSizedBuffer 

func (m *ActorMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActorMessage) Message 

func (s *ActorMessage) Message() interface{}

func (*ActorMessage) ProtoMessage 

func (*ActorMessage) ProtoMessage()

func (*ActorMessage) Reset 

func (m *ActorMessage) Reset()

func (*ActorMessage) SetMessage added in v1.1.20 

func (s *ActorMessage) SetMessage(v interface{})

func (*ActorMessage) Size 

func (m *ActorMessage) Size() (n int)

func (*ActorMessage) String 

func (m *ActorMessage) String() string

func (*ActorMessage) UnlockFree added in v1.1.20 

func (msg *ActorMessage) UnlockFree()

func (*ActorMessage) Unmarshal 

func (m *ActorMessage) Unmarshal(dAtA []byte) error

func (*ActorMessage) XXX_DiscardUnknown 

func (m *ActorMessage) XXX_DiscardUnknown()

func (*ActorMessage) XXX_Marshal 

func (m *ActorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActorMessage) XXX_Merge 

func (m *ActorMessage) XXX_Merge(src proto.Message)

func (*ActorMessage) XXX_Size 

func (m *ActorMessage) XXX_Size() int

func (*ActorMessage) XXX_Unmarshal 

func (m *ActorMessage) XXX_Unmarshal(b []byte) error

type EventMessage 

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

func NewEventMessage 

func NewEventMessage(actEvent interface{}) *EventMessage

func (*EventMessage) ActEvent 

func (s *EventMessage) ActEvent() interface{}

func (*EventMessage) Free 

func (s *EventMessage) Free()

func (*EventMessage) String 

func (s *EventMessage) String() string

type Message added in v1.1.20 

type Message interface {
	Free()
	GetSourceId() string
	GetTargetId() string
	GetRequestId() string
	GetMsgName() string
	Message() interface{}
	String() string
}

type RequestDeadLetter 

type RequestDeadLetter struct {
	Err string `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
}

func (*RequestDeadLetter) Descriptor 

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

func (*RequestDeadLetter) GetErr 

func (m *RequestDeadLetter) GetErr() string

func (*RequestDeadLetter) Marshal 

func (m *RequestDeadLetter) Marshal() (dAtA []byte, err error)

func (*RequestDeadLetter) MarshalTo 

func (m *RequestDeadLetter) MarshalTo(dAtA []byte) (int, error)

func (*RequestDeadLetter) MarshalToSizedBuffer 

func (m *RequestDeadLetter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestDeadLetter) ProtoMessage 

func (*RequestDeadLetter) ProtoMessage()

func (*RequestDeadLetter) Reset 

func (m *RequestDeadLetter) Reset()

func (*RequestDeadLetter) Size 

func (m *RequestDeadLetter) Size() (n int)

func (*RequestDeadLetter) String 

func (m *RequestDeadLetter) String() string

func (*RequestDeadLetter) Unmarshal 

func (m *RequestDeadLetter) Unmarshal(dAtA []byte) error

func (*RequestDeadLetter) XXX_DiscardUnknown 

func (m *RequestDeadLetter) XXX_DiscardUnknown()

func (*RequestDeadLetter) XXX_Marshal 

func (m *RequestDeadLetter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestDeadLetter) XXX_Merge 

func (m *RequestDeadLetter) XXX_Merge(src proto.Message)

func (*RequestDeadLetter) XXX_Size 

func (m *RequestDeadLetter) XXX_Size() int

func (*RequestDeadLetter) XXX_Unmarshal 

func (m *RequestDeadLetter) XXX_Unmarshal(b []byte) error

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.