Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Callbacks ¶
type Callbacks struct {
OnMappingSyncRequestReceived func(request *mesh_proto.MappingSyncRequest) error
OnMetadataSyncRequestReceived func(request *mesh_proto.MetadataSyncRequest) error
}
type DubboSyncClient ¶
type DubboSyncClient interface {
ClientID() string
HandleReceive() error
Send(resourceList core_model.ResourceList, revision int64) error
}
DubboSyncClient Handle Dubbo Sync Request from client
func NewDubboSyncClient ¶
func NewDubboSyncClient(log logr.Logger, id string, syncStream DubboSyncStream, cb *Callbacks) DubboSyncClient
type DubboSyncStream ¶
type DubboSyncStream interface {
Recv() (proto.Message, error)
Send(resourceList core_model.ResourceList, revision int64) error
SubscribedInterfaceNames() []string
SubscribedApplicationNames() []string
}
func NewDubboSyncStream ¶
func NewDubboSyncStream(streamClient grpc.ServerStream) DubboSyncStream
Click to show internal directories.
Click to hide internal directories.