Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GlobalDDSServiceServer ¶
type GlobalDDSServiceServer struct {
mesh_proto.UnimplementedGlobalDDSServiceServer
// contains filtered or unexported fields
}
func NewGlobalDDSServiceServer ¶
func NewGlobalDDSServiceServer( ctx context.Context, resManager manager.ResourceManager, instanceID string, filters []StreamInterceptor, extensions context.Context, upsertCfg config_store.UpsertConfig, eventBus events.EventBus, zoneHealthCheckInterval time.Duration, ) *GlobalDDSServiceServer
func (*GlobalDDSServiceServer) HealthCheck ¶
func (g *GlobalDDSServiceServer) HealthCheck(ctx context.Context, _ *mesh_proto.ZoneHealthCheckRequest) (*mesh_proto.ZoneHealthCheckResponse, error)
type StreamInterceptor ¶
type StreamInterceptor interface {
InterceptServerStream(stream grpc.ServerStream) error
}
type ZoneClientID ¶
type ZoneClientID struct {
Zone string
}
func ZoneClientIDFromCtx ¶
func ZoneClientIDFromCtx(ctx context.Context, zone string) ZoneClientID
func (ZoneClientID) String ¶
func (id ZoneClientID) String() string
type ZoneOpenedStream ¶
type ZoneOpenedStream struct {
Zone string
}
type ZoneWentOffline ¶
type ZoneWentOffline struct {
Zone string
}
Source Files
Click to show internal directories.
Click to hide internal directories.