client

package
v0.0.0-...-83c1a15 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL