innermsg

Documentation

Index

• Variables
• func RegisterActorServiceServer(s *grpc.Server, srv ActorServiceServer)
• type ActorMessage
  • func NewActorMessage() *ActorMessage
  • func (*ActorMessage) Descriptor() ([]byte, []int)
  • 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 (*ActorMessage) ProtoMessage()
  • 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
  • func NewActorServiceClient(cc *grpc.ClientConn) ActorServiceClient
• type ActorServiceServer
• type ActorService_ReceiveClient
• type ActorService_ReceiveServer
• type RequestDeadLetter
  • func (*RequestDeadLetter) Descriptor() ([]byte, []int)
  • 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 (*RequestDeadLetter) ProtoMessage()
  • 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
  • func (*UnimplementedActorServiceServer) Receive(srv ActorService_ReceiveServer) error

Variables

var (
	ErrInvalidLengthMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterActorServiceServer

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

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

func NewActorMessage() *ActorMessage

func (*ActorMessage) Descriptor

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

func (*ActorMessage) Free

func (m *ActorMessage) Free()

func (*ActorMessage) GetData

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

func (*ActorMessage) GetMapCarrier

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) 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) Parse

func (m *ActorMessage) Parse(pi *tools.ProtoIndex)

func (*ActorMessage) Payload

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

func (*ActorMessage) ProtoMessage

func (*ActorMessage) ProtoMessage()

func (*ActorMessage) Reset

func (m *ActorMessage) Reset()

func (*ActorMessage) SetPayload

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

func (*ActorMessage) Size

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

func (*ActorMessage) String

func (m *ActorMessage) String() string

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 ActorServiceClient

type ActorServiceClient interface {
	Receive(ctx context.Context, opts ...grpc.CallOption) (ActorService_ReceiveClient, error)
}

ActorServiceClient is the client API for ActorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewActorServiceClient

func NewActorServiceClient(cc *grpc.ClientConn) ActorServiceClient

type ActorServiceServer

type ActorServiceServer interface {
	Receive(ActorService_ReceiveServer) error
}

ActorServiceServer is the server API for ActorService service.

type ActorService_ReceiveClient

type ActorService_ReceiveClient interface {
	Send(*ActorMessage) error
	Recv() (*ActorMessage, error)
	grpc.ClientStream
}

type ActorService_ReceiveServer

type ActorService_ReceiveServer interface {
	Send(*ActorMessage) error
	Recv() (*ActorMessage, error)
	grpc.ServerStream
}

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

type UnimplementedActorServiceServer

type UnimplementedActorServiceServer struct {
}

UnimplementedActorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedActorServiceServer) Receive

func (*UnimplementedActorServiceServer) Receive(srv ActorService_ReceiveServer) error