client

Documentation

Index

• type Callbacks
• type DubboSyncClient
  • func NewDubboSyncClient(log logr.Logger, id string, syncStream DubboSyncStream, cb *Callbacks) DubboSyncClient
• type DubboSyncStream
  • func NewDubboSyncStream(streamClient grpc.ServerStream) DubboSyncStream

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