proxypb

package
v0.0.0-...-d853fe5 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

Deprecated: Use PingPong.ProtoReflect.Descriptor instead.

func (*PingPong) ProtoMessage 

func (*PingPong) ProtoMessage()

func (*PingPong) ProtoReflect 

func (x *PingPong) ProtoReflect() protoreflect.Message

func (*PingPong) Reset 

func (x *PingPong) Reset()

func (*PingPong) String 

func (x *PingPong) String() string

type ProxyEty 

type ProxyEty struct {
	EntityID entity.EntityID
}

func NewProxyEty 

func NewProxyEty(c entity.Context) (*ProxyEty, error)

func NewProxyEtyClient 

func NewProxyEtyClient(eid entity.EntityID) *ProxyEty

func NewProxyEtyWithID 

func NewProxyEtyWithID(c entity.Context, id entity.EntityID) (*ProxyEty, error)

func (*ProxyEty) Ping 

func (t *ProxyEty) Ping(c entity.Context, req *PingPong) (*PingPong, error)

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

func (t *ProxySvc) Ping(c entity.Context, req *PingPong) (*PingPong, error)

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

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.