mux

Documentation

Index

• Constants
• func NewClient(ctx context.Context, globalURL string, clientID string, ...) component.Component
• func NewServer(filters []Filter, streamInterceptors []grpc.StreamServerInterceptor, ...) component.Component
• type DDSSyncServiceServer
  • func NewDDSSyncServiceServer(ctx context.Context, globalToZoneCb OnGlobalToZoneSyncConnectFunc, ...) *DDSSyncServiceServer
  • func (g *DDSSyncServiceServer) GlobalToZoneSync(stream mesh_proto.DDSSyncService_GlobalToZoneSyncServer) error
  • func (g *DDSSyncServiceServer) ZoneToGlobalSync(stream mesh_proto.DDSSyncService_ZoneToGlobalSyncServer) error
• type Filter
• type OnGlobalToZoneSyncConnectFunc
  • func (f OnGlobalToZoneSyncConnectFunc) OnGlobalToZoneSyncConnect(stream mesh_proto.DDSSyncService_GlobalToZoneSyncServer, errorChan chan error)
• type OnGlobalToZoneSyncStartedFunc
  • func (f OnGlobalToZoneSyncStartedFunc) OnGlobalToZoneSyncStarted(session mesh_proto.DDSSyncService_GlobalToZoneSyncClient, errorCh chan error)
• type OnZoneToGlobalSyncConnectFunc
  • func (f OnZoneToGlobalSyncConnectFunc) OnZoneToGlobalSyncConnect(stream mesh_proto.DDSSyncService_ZoneToGlobalSyncServer, errorCh chan error)
• type OnZoneToGlobalSyncStartedFunc
  • func (f OnZoneToGlobalSyncStartedFunc) OnZoneToGlobalSyncStarted(session mesh_proto.DDSSyncService_ZoneToGlobalSyncClient, errorCh chan error)
• type ZoneWatch
  • func NewZoneWatch(log logr.Logger, cfg multizone.ZoneHealthCheckConfig, bus events.EventBus, ...) (*ZoneWatch, error)
  • func (zw *ZoneWatch) NeedLeaderElection() bool
  • func (zw *ZoneWatch) Start(stop <-chan struct{}) error

Constants

const (
	DDSVersionHeaderKey = "dds-version"
	DDSVersionV3        = "v3"
)

Functions

func NewClient

func NewClient(
	ctx context.Context,
	globalURL string,
	clientID string,
	globalToZoneCb OnGlobalToZoneSyncStartedFunc,
	zoneToGlobalCb OnZoneToGlobalSyncStartedFunc,
	config multizone.DdsClientConfig,
) component.Component

func NewServer

func NewServer(
	filters []Filter,
	streamInterceptors []grpc.StreamServerInterceptor,
	unaryInterceptors []grpc.UnaryServerInterceptor,
	config multizone.DdsServerConfig,
	serviceServer *service.GlobalDDSServiceServer,
	ddsSyncServiceServer *DDSSyncServiceServer,
) component.Component

Types

type DDSSyncServiceServer

type DDSSyncServiceServer struct {
	mesh_proto.UnimplementedDDSSyncServiceServer
	// contains filtered or unexported fields
}

func NewDDSSyncServiceServer

func NewDDSSyncServiceServer(ctx context.Context, globalToZoneCb OnGlobalToZoneSyncConnectFunc, zoneToGlobalCb OnZoneToGlobalSyncConnectFunc, filters []Filter, extensions context.Context, eventBus events.EventBus) *DDSSyncServiceServer

func (*DDSSyncServiceServer) GlobalToZoneSync

func (g *DDSSyncServiceServer) GlobalToZoneSync(stream mesh_proto.DDSSyncService_GlobalToZoneSyncServer) error

func (*DDSSyncServiceServer) ZoneToGlobalSync

func (g *DDSSyncServiceServer) ZoneToGlobalSync(stream mesh_proto.DDSSyncService_ZoneToGlobalSyncServer) error

type Filter

type Filter interface {
	InterceptServerStream(stream grpc.ServerStream) error
	InterceptClientStream(stream grpc.ClientStream) error
}

type OnGlobalToZoneSyncConnectFunc

type OnGlobalToZoneSyncConnectFunc func(stream mesh_proto.DDSSyncService_GlobalToZoneSyncServer, errorCh chan error)

func (OnGlobalToZoneSyncConnectFunc) OnGlobalToZoneSyncConnect

func (f OnGlobalToZoneSyncConnectFunc) OnGlobalToZoneSyncConnect(stream mesh_proto.DDSSyncService_GlobalToZoneSyncServer, errorChan chan error)

type OnGlobalToZoneSyncStartedFunc

type OnGlobalToZoneSyncStartedFunc func(session mesh_proto.DDSSyncService_GlobalToZoneSyncClient, errorCh chan error)

func (OnGlobalToZoneSyncStartedFunc) OnGlobalToZoneSyncStarted

func (f OnGlobalToZoneSyncStartedFunc) OnGlobalToZoneSyncStarted(session mesh_proto.DDSSyncService_GlobalToZoneSyncClient, errorCh chan error)

type OnZoneToGlobalSyncConnectFunc

type OnZoneToGlobalSyncConnectFunc func(stream mesh_proto.DDSSyncService_ZoneToGlobalSyncServer, errorCh chan error)

func (OnZoneToGlobalSyncConnectFunc) OnZoneToGlobalSyncConnect

func (f OnZoneToGlobalSyncConnectFunc) OnZoneToGlobalSyncConnect(stream mesh_proto.DDSSyncService_ZoneToGlobalSyncServer, errorCh chan error)

type OnZoneToGlobalSyncStartedFunc

type OnZoneToGlobalSyncStartedFunc func(session mesh_proto.DDSSyncService_ZoneToGlobalSyncClient, errorCh chan error)

func (OnZoneToGlobalSyncStartedFunc) OnZoneToGlobalSyncStarted

func (f OnZoneToGlobalSyncStartedFunc) OnZoneToGlobalSyncStarted(session mesh_proto.DDSSyncService_ZoneToGlobalSyncClient, errorCh chan error)

type ZoneWatch

type ZoneWatch struct {
	// contains filtered or unexported fields
}

func NewZoneWatch

func NewZoneWatch(
	log logr.Logger,
	cfg multizone.ZoneHealthCheckConfig,
	bus events.EventBus,
	rm manager.ReadOnlyResourceManager,
	extensions context.Context,
) (*ZoneWatch, error)

func (*ZoneWatch) NeedLeaderElection

func (zw *ZoneWatch) NeedLeaderElection() bool

func (*ZoneWatch) Start

func (zw *ZoneWatch) Start(stop <-chan struct{}) error