actor_msg

Nov 29, 2022

Changes in this version

type ActorMessage

+ func (s *ActorMessage) RawMsg() interface{}

Oct 6, 2022

Changes in this version

type ActorMessage

+ MapCarrier map[string]string

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

Jan 30, 2022

Changes in this version

type ActorMessage

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

Jan 14, 2022

Changes in this version

type ActorMessage

+ func NewActorMessage() *ActorMessage

+ func (msg *ActorMessage) LockFree()

+ func (msg *ActorMessage) UnlockFree()

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

type ActorServiceClient

+ Test func(ctx context.Context, opts ...grpc.CallOption) (ActorService_TestClient, error)

type ActorServiceServer

+ Test func(ActorService_TestServer) error

+ type ActorService_TestClient interface

+ CloseAndRecv func() (*ActorMessage, error)

+ Send func(*ActorMessage) error

+ type ActorService_TestServer interface

+ Recv func() (*ActorMessage, error)

+ SendAndClose func(*ActorMessage) error

+ type Message interface

+ Free func()

+ GetMsgName func() string

+ GetRequestId func() string

+ GetSourceId func() string

+ GetTargetId func() string

+ Message func() interface{}

+ String func() string

type UnimplementedActorServiceServer

+ func (*UnimplementedActorServiceServer) Test(srv ActorService_TestServer) error

Aug 22, 2021

Changes in this version

+ var ErrIntOverflowActorMsg = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthActorMsg = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupActorMsg = fmt.Errorf("proto: unexpected end of group")

+ func RegisterActorServiceServer(s *grpc.Server, srv ActorServiceServer)

+ type ActorMessage struct

+ Data []byte

+ MsgName string

+ RequestId string

+ SourceId string

+ TargetId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewLocalActorMessage(sourceId, targetId, requestId string, message interface{}) *ActorMessage

+ func NewNetActorMessage(sourceId, targetId, requestId string, msgName string, data []byte) *ActorMessage

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

+ func (*ActorMessage) ProtoMessage()

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

+ func (m *ActorMessage) GetMsgName() string

+ func (m *ActorMessage) GetRequestId() string

+ func (m *ActorMessage) GetSourceId() string

+ func (m *ActorMessage) GetTargetId() string

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

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

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

+ func (m *ActorMessage) Reset()

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

+ func (m *ActorMessage) String() string

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

+ func (m *ActorMessage) XXX_DiscardUnknown()

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

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

+ func (m *ActorMessage) XXX_Size() int

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

+ func (msg *ActorMessage) Free()

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

+ type ActorServiceClient interface

+ Receive func(ctx context.Context, opts ...grpc.CallOption) (ActorService_ReceiveClient, error)

+ func NewActorServiceClient(cc *grpc.ClientConn) ActorServiceClient

+ type ActorServiceServer interface

+ Receive func(ActorService_ReceiveServer) error

+ type ActorService_ReceiveClient interface

+ Recv func() (*ActorMessage, error)

+ Send func(*ActorMessage) error

+ type ActorService_ReceiveServer interface

+ Recv func() (*ActorMessage, error)

+ Send func(*ActorMessage) error

+ type EventMessage struct

+ func NewEventMessage(actEvent interface{}) *EventMessage

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

+ func (s *EventMessage) Free()

+ func (s *EventMessage) String() string

+ type IMessage interface

+ Free func()

+ String func() string

+ type RequestDeadLetter struct

+ Err string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RequestDeadLetter) ProtoMessage()

+ func (m *RequestDeadLetter) GetErr() string

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

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

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

+ func (m *RequestDeadLetter) Reset()

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

+ func (m *RequestDeadLetter) String() string

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

+ func (m *RequestDeadLetter) XXX_DiscardUnknown()

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

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

+ func (m *RequestDeadLetter) XXX_Size() int

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

+ type UnimplementedActorServiceServer struct

+ func (*UnimplementedActorServiceServer) Receive(srv ActorService_ReceiveServer) error