remote

type Endpoint struct {
	Name       string
	Addr       string
	Attributes *attributes.Attributes
	// contains filtered or unexported fields
}

type Error struct {
	Code   int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Detail string `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {
	From      *PID      `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	RequestId int64     `protobuf:"varint,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Data      *any1.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Flag      int32     `protobuf:"varint,4,opt,name=flag,proto3" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

type MessageCodec interface {
	Marshal(m proto.Message) (*anypb.Any, error)
	Unmarshal(v *anypb.Any) (proto.Message, error)
}

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

type OnMessageRequest struct {
	To      *PID     `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"`
	Message *Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type PID struct {
	Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Id   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type RemoteClient interface {
	OnMessage(ctx context.Context, in *OnMessageRequest, opts ...grpc.CallOption) (*OnMessageReply, error)
}

type RemoteServer interface {
	OnMessage(context.Context, *OnMessageRequest) (*OnMessageReply, error)
	// contains filtered or unexported methods
}

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

type UnimplementedRemoteServer struct {
}

type UnsafeRemoteServer interface {
	// contains filtered or unexported methods
}