actor_msg

package
v1.2.12 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2022 License: GPL-3.0 Imports: 14 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

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"`
	// 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) 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 ActorServiceClient 

type ActorServiceClient interface {
	Receive(ctx context.Context, opts ...grpc.CallOption) (ActorService_ReceiveClient, error)
	Test(ctx context.Context, opts ...grpc.CallOption) (ActorService_TestClient, 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
	Test(ActorService_TestServer) 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 ActorService_TestClient added in v1.1.20 

type ActorService_TestClient interface {
	Send(*ActorMessage) error
	CloseAndRecv() (*ActorMessage, error)
	grpc.ClientStream
}

type ActorService_TestServer added in v1.1.20 

type ActorService_TestServer interface {
	SendAndClose(*ActorMessage) error
	Recv() (*ActorMessage, error)
	grpc.ServerStream
}

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

type UnimplementedActorServiceServer 

type UnimplementedActorServiceServer struct {
}

UnimplementedActorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedActorServiceServer) Receive 

func (*UnimplementedActorServiceServer) Receive(srv ActorService_ReceiveServer) error

func (*UnimplementedActorServiceServer) Test added in v1.1.20 

func (*UnimplementedActorServiceServer) Test(srv ActorService_TestServer) 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.