innermsg

Apr 16, 2023

Changes in this version

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

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

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

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

+ type ActorMessage struct

+ Data []byte

+ MapCarrier map[string]string

+ MsgName string

+ RequestId string

+ SourceId string

+ TargetId string

+ func NewActorMessage() *ActorMessage

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

+ func (*ActorMessage) ProtoMessage()

+ func (m *ActorMessage) Free()

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

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

+ 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) Parse(pi *tools.ProtoIndex)

+ func (m *ActorMessage) Payload() interface{}

+ func (m *ActorMessage) Reset()

+ func (m *ActorMessage) SetPayload(v interface{})

+ 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

+ 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 RequestDeadLetter struct

+ Err string

+ 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