service

Documentation

Index

• type GlobalDDSServiceServer
  • func NewGlobalDDSServiceServer(ctx context.Context, resManager manager.ResourceManager, instanceID string, ...) *GlobalDDSServiceServer
  • func (g *GlobalDDSServiceServer) HealthCheck(ctx context.Context, _ *mesh_proto.ZoneHealthCheckRequest) (*mesh_proto.ZoneHealthCheckResponse, error)
• type StreamInterceptor
• type ZoneClientID
  • func ZoneClientIDFromCtx(ctx context.Context, zone string) ZoneClientID
  • func (id ZoneClientID) String() string
• type ZoneOpenedStream
• type ZoneWentOffline

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
}