Documentation ¶
Index ¶
- Variables
- func RegisterProxyEtyEntity(etyMgr *entity.EntityManager, impl ProxyEtyEntity)
- func RegisterProxySvcService(etyMgr *entity.EntityManager, impl ProxySvcService)
- type PingPong
- type ProxyEty
- func (t *ProxyEty) Ping(c entity.Context, req *PingPong) (*PingPong, error)
- func (t *ProxyEty) RegisterProxy(c entity.Context, req *RegisterProxyRequest) (*RegisterProxyResponse, error)
- func (t *ProxyEty) RegisterService(c entity.Context, req *RegisterServiceRequest) (*RegisterServiceResponse, error)
- func (t *ProxyEty) SyncService(c entity.Context, req *SyncServiceRequest) (*SyncServiceResponse, error)
- func (t *ProxyEty) UnregisterService(c entity.Context, req *RegisterServiceRequest) (*RegisterServiceResponse, error)
- type ProxyEtyEntity
- type ProxySvc
- type ProxySvcService
- type RegisterInstRequest
- type RegisterInstResponse
- func (*RegisterInstResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterInstResponse) GetInstID() uint32
- func (x *RegisterInstResponse) GetProxyID() uint32
- func (*RegisterInstResponse) ProtoMessage()
- func (x *RegisterInstResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterInstResponse) Reset()
- func (x *RegisterInstResponse) String() string
- type RegisterProxyRequest
- func (*RegisterProxyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterProxyRequest) GetProxyID() uint32
- func (*RegisterProxyRequest) ProtoMessage()
- func (x *RegisterProxyRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterProxyRequest) Reset()
- func (x *RegisterProxyRequest) String() string
- type RegisterProxyResponse
- func (*RegisterProxyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterProxyResponse) GetEntityNames() []string
- func (x *RegisterProxyResponse) GetServiceNames() []string
- func (*RegisterProxyResponse) ProtoMessage()
- func (x *RegisterProxyResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterProxyResponse) Reset()
- func (x *RegisterProxyResponse) String() string
- type RegisterServiceRequest
- func (*RegisterServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterServiceRequest) GetServiceName() string
- func (*RegisterServiceRequest) ProtoMessage()
- func (x *RegisterServiceRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterServiceRequest) Reset()
- func (x *RegisterServiceRequest) String() string
- type RegisterServiceResponse
- type SyncServiceRequest
- func (*SyncServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncServiceRequest) GetProxyID() uint32
- func (x *SyncServiceRequest) GetSvcName() string
- func (*SyncServiceRequest) ProtoMessage()
- func (x *SyncServiceRequest) ProtoReflect() protoreflect.Message
- func (x *SyncServiceRequest) Reset()
- func (x *SyncServiceRequest) String() string
- type SyncServiceResponse
Constants ¶
This section is empty.
Variables ¶
View Source
var File_proxy_proto protoreflect.FileDescriptor
View Source
var ProxyEtyEntityDesc = entity.EntityDesc{ TypeName: "proxypb.ProxyEtyEntity", HandlerType: (*ProxyEtyEntity)(nil), Methods: map[string]entity.MethodDesc{ "RegisterProxy": { MethodName: "RegisterProxy", Handler: _ProxyEtyEntity_RegisterProxy_Remote_Handler, LocalHandler: _ProxyEtyEntity_RegisterProxy_Local_Handler, }, "SyncService": { MethodName: "SyncService", Handler: _ProxyEtyEntity_SyncService_Remote_Handler, LocalHandler: _ProxyEtyEntity_SyncService_Local_Handler, }, "RegisterService": { MethodName: "RegisterService", Handler: _ProxyEtyEntity_RegisterService_Remote_Handler, LocalHandler: _ProxyEtyEntity_RegisterService_Local_Handler, }, "UnregisterService": { MethodName: "UnregisterService", Handler: _ProxyEtyEntity_UnregisterService_Remote_Handler, LocalHandler: _ProxyEtyEntity_UnregisterService_Local_Handler, }, "Ping": { MethodName: "Ping", Handler: _ProxyEtyEntity_Ping_Remote_Handler, LocalHandler: _ProxyEtyEntity_Ping_Local_Handler, }, }, Metadata: "proxy.proto", }
View Source
var ProxySvcServiceDesc = entity.EntityDesc{ TypeName: "proxypb.ProxySvcService", HandlerType: (*ProxySvcService)(nil), Methods: map[string]entity.MethodDesc{ "RegisterInst": { MethodName: "RegisterInst", Handler: _ProxySvcService_RegisterInst_Remote_Handler, LocalHandler: _ProxySvcService_RegisterInst_Local_Handler, }, "Ping": { MethodName: "Ping", Handler: _ProxySvcService_Ping_Remote_Handler, LocalHandler: _ProxySvcService_Ping_Local_Handler, }, }, Metadata: "proxy.proto", }
Functions ¶
func RegisterProxyEtyEntity ¶
func RegisterProxyEtyEntity(etyMgr *entity.EntityManager, impl ProxyEtyEntity)
func RegisterProxySvcService ¶
func RegisterProxySvcService(etyMgr *entity.EntityManager, impl ProxySvcService)
Types ¶
type PingPong ¶
type PingPong struct {
// contains filtered or unexported fields
}
func (*PingPong) Descriptor
deprecated
func (*PingPong) ProtoMessage ¶
func (*PingPong) ProtoMessage()
func (*PingPong) ProtoReflect ¶
func (x *PingPong) ProtoReflect() protoreflect.Message
type ProxyEty ¶
func NewProxyEtyClient ¶
func NewProxyEtyWithID ¶
func (*ProxyEty) RegisterProxy ¶
func (t *ProxyEty) RegisterProxy(c entity.Context, req *RegisterProxyRequest) (*RegisterProxyResponse, error)
func (*ProxyEty) RegisterService ¶
func (t *ProxyEty) RegisterService(c entity.Context, req *RegisterServiceRequest) (*RegisterServiceResponse, error)
func (*ProxyEty) SyncService ¶
func (t *ProxyEty) SyncService(c entity.Context, req *SyncServiceRequest) (*SyncServiceResponse, error)
func (*ProxyEty) UnregisterService ¶
func (t *ProxyEty) UnregisterService(c entity.Context, req *RegisterServiceRequest) (*RegisterServiceResponse, error)
type ProxyEtyEntity ¶
type ProxyEtyEntity interface { entity.IEntity // RegisterProxy RegisterProxy(c entity.Context, req *RegisterProxyRequest) (*RegisterProxyResponse, error) // SyncService SyncService(c entity.Context, req *SyncServiceRequest) (*SyncServiceResponse, error) // RegisterService RegisterService(c entity.Context, req *RegisterServiceRequest) (*RegisterServiceResponse, error) // UnregisterService UnregisterService(c entity.Context, req *RegisterServiceRequest) (*RegisterServiceResponse, error) // Ping Ping(c entity.Context, req *PingPong) (*PingPong, error) }
ProxyEtyEntity
type ProxySvc ¶
type ProxySvc struct { }
func NewProxySvcClient ¶
func NewProxySvcClient() *ProxySvc
func (*ProxySvc) RegisterInst ¶
func (t *ProxySvc) RegisterInst(c entity.Context, req *RegisterInstRequest) (*RegisterInstResponse, error)
type ProxySvcService ¶
type ProxySvcService interface { entity.IService // RegisterInst RegisterInst(c entity.Context, req *RegisterInstRequest) (*RegisterInstResponse, error) // Ping Ping(c entity.Context, req *PingPong) (*PingPong, error) }
ProxySvcService
type RegisterInstRequest ¶
type RegisterInstRequest struct {
// contains filtered or unexported fields
}
func (*RegisterInstRequest) Descriptor
deprecated
func (*RegisterInstRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterInstRequest.ProtoReflect.Descriptor instead.
func (*RegisterInstRequest) ProtoMessage ¶
func (*RegisterInstRequest) ProtoMessage()
func (*RegisterInstRequest) ProtoReflect ¶
func (x *RegisterInstRequest) ProtoReflect() protoreflect.Message
func (*RegisterInstRequest) Reset ¶
func (x *RegisterInstRequest) Reset()
func (*RegisterInstRequest) String ¶
func (x *RegisterInstRequest) String() string
type RegisterInstResponse ¶
type RegisterInstResponse struct { ProxyID uint32 `protobuf:"varint,1,opt,name=ProxyID,proto3" json:"ProxyID,omitempty" bson:"ProxyID"` //uint16 InstID uint32 `protobuf:"varint,2,opt,name=InstID,proto3" json:"InstID,omitempty" bson:"InstID"` //uint16 // contains filtered or unexported fields }
func (*RegisterInstResponse) Descriptor
deprecated
func (*RegisterInstResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterInstResponse.ProtoReflect.Descriptor instead.
func (*RegisterInstResponse) GetInstID ¶
func (x *RegisterInstResponse) GetInstID() uint32
func (*RegisterInstResponse) GetProxyID ¶
func (x *RegisterInstResponse) GetProxyID() uint32
func (*RegisterInstResponse) ProtoMessage ¶
func (*RegisterInstResponse) ProtoMessage()
func (*RegisterInstResponse) ProtoReflect ¶
func (x *RegisterInstResponse) ProtoReflect() protoreflect.Message
func (*RegisterInstResponse) Reset ¶
func (x *RegisterInstResponse) Reset()
func (*RegisterInstResponse) String ¶
func (x *RegisterInstResponse) String() string
type RegisterProxyRequest ¶
type RegisterProxyRequest struct { ProxyID uint32 `protobuf:"varint,1,opt,name=ProxyID,proto3" json:"ProxyID,omitempty" bson:"ProxyID"` // contains filtered or unexported fields }
func (*RegisterProxyRequest) Descriptor
deprecated
func (*RegisterProxyRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterProxyRequest.ProtoReflect.Descriptor instead.
func (*RegisterProxyRequest) GetProxyID ¶
func (x *RegisterProxyRequest) GetProxyID() uint32
func (*RegisterProxyRequest) ProtoMessage ¶
func (*RegisterProxyRequest) ProtoMessage()
func (*RegisterProxyRequest) ProtoReflect ¶
func (x *RegisterProxyRequest) ProtoReflect() protoreflect.Message
func (*RegisterProxyRequest) Reset ¶
func (x *RegisterProxyRequest) Reset()
func (*RegisterProxyRequest) String ¶
func (x *RegisterProxyRequest) String() string
type RegisterProxyResponse ¶
type RegisterProxyResponse struct { ServiceNames []string `protobuf:"bytes,1,rep,name=ServiceNames,proto3" json:"ServiceNames,omitempty" bson:"ServiceNames"` EntityNames []string `protobuf:"bytes,2,rep,name=EntityNames,proto3" json:"EntityNames,omitempty" bson:"EntityNames"` // contains filtered or unexported fields }
func (*RegisterProxyResponse) Descriptor
deprecated
func (*RegisterProxyResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterProxyResponse.ProtoReflect.Descriptor instead.
func (*RegisterProxyResponse) GetEntityNames ¶
func (x *RegisterProxyResponse) GetEntityNames() []string
func (*RegisterProxyResponse) GetServiceNames ¶
func (x *RegisterProxyResponse) GetServiceNames() []string
func (*RegisterProxyResponse) ProtoMessage ¶
func (*RegisterProxyResponse) ProtoMessage()
func (*RegisterProxyResponse) ProtoReflect ¶
func (x *RegisterProxyResponse) ProtoReflect() protoreflect.Message
func (*RegisterProxyResponse) Reset ¶
func (x *RegisterProxyResponse) Reset()
func (*RegisterProxyResponse) String ¶
func (x *RegisterProxyResponse) String() string
type RegisterServiceRequest ¶
type RegisterServiceRequest struct { ServiceName string `protobuf:"bytes,1,opt,name=ServiceName,proto3" json:"ServiceName,omitempty" bson:"ServiceName"` // contains filtered or unexported fields }
func (*RegisterServiceRequest) Descriptor
deprecated
func (*RegisterServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterServiceRequest.ProtoReflect.Descriptor instead.
func (*RegisterServiceRequest) GetServiceName ¶
func (x *RegisterServiceRequest) GetServiceName() string
func (*RegisterServiceRequest) ProtoMessage ¶
func (*RegisterServiceRequest) ProtoMessage()
func (*RegisterServiceRequest) ProtoReflect ¶
func (x *RegisterServiceRequest) ProtoReflect() protoreflect.Message
func (*RegisterServiceRequest) Reset ¶
func (x *RegisterServiceRequest) Reset()
func (*RegisterServiceRequest) String ¶
func (x *RegisterServiceRequest) String() string
type RegisterServiceResponse ¶
type RegisterServiceResponse struct {
// contains filtered or unexported fields
}
func (*RegisterServiceResponse) Descriptor
deprecated
func (*RegisterServiceResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterServiceResponse.ProtoReflect.Descriptor instead.
func (*RegisterServiceResponse) ProtoMessage ¶
func (*RegisterServiceResponse) ProtoMessage()
func (*RegisterServiceResponse) ProtoReflect ¶
func (x *RegisterServiceResponse) ProtoReflect() protoreflect.Message
func (*RegisterServiceResponse) Reset ¶
func (x *RegisterServiceResponse) Reset()
func (*RegisterServiceResponse) String ¶
func (x *RegisterServiceResponse) String() string
type SyncServiceRequest ¶
type SyncServiceRequest struct { ProxyID uint32 `protobuf:"varint,1,opt,name=ProxyID,proto3" json:"ProxyID,omitempty" bson:"ProxyID"` SvcName string `protobuf:"bytes,2,opt,name=SvcName,proto3" json:"SvcName,omitempty" bson:"SvcName"` // contains filtered or unexported fields }
func (*SyncServiceRequest) Descriptor
deprecated
func (*SyncServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncServiceRequest.ProtoReflect.Descriptor instead.
func (*SyncServiceRequest) GetProxyID ¶
func (x *SyncServiceRequest) GetProxyID() uint32
func (*SyncServiceRequest) GetSvcName ¶
func (x *SyncServiceRequest) GetSvcName() string
func (*SyncServiceRequest) ProtoMessage ¶
func (*SyncServiceRequest) ProtoMessage()
func (*SyncServiceRequest) ProtoReflect ¶
func (x *SyncServiceRequest) ProtoReflect() protoreflect.Message
func (*SyncServiceRequest) Reset ¶
func (x *SyncServiceRequest) Reset()
func (*SyncServiceRequest) String ¶
func (x *SyncServiceRequest) String() string
type SyncServiceResponse ¶
type SyncServiceResponse struct {
// contains filtered or unexported fields
}
func (*SyncServiceResponse) Descriptor
deprecated
func (*SyncServiceResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncServiceResponse.ProtoReflect.Descriptor instead.
func (*SyncServiceResponse) ProtoMessage ¶
func (*SyncServiceResponse) ProtoMessage()
func (*SyncServiceResponse) ProtoReflect ¶
func (x *SyncServiceResponse) ProtoReflect() protoreflect.Message
func (*SyncServiceResponse) Reset ¶
func (x *SyncServiceResponse) Reset()
func (*SyncServiceResponse) String ¶
func (x *SyncServiceResponse) String() string
Click to show internal directories.
Click to hide internal directories.