multicluster

Documentation

Index

• func Assign(ctx context.Context, obj client.Object, ordinal func() int) client.Object
• func FromContext(ctx context.Context) (string, error)
• func IntoContext(ctx context.Context, placement string) context.Context
• func NewClient(control client.Client, workers map[string]client.Client) client.Client
• type ClientOption
  • func InControlContext() *ClientOption
  • func InDataContext() *ClientOption
  • func InDataContextUnspecified() *ClientOption
  • func InUniversalContext() *ClientOption
  • func (o *ClientOption) ApplyToCreate(*client.CreateOptions)
  • func (o *ClientOption) ApplyToDelete(*client.DeleteOptions)
  • func (o *ClientOption) ApplyToDeleteAllOf(*client.DeleteAllOfOptions)
  • func (o *ClientOption) ApplyToGet(*client.GetOptions)
  • func (o *ClientOption) ApplyToList(*client.ListOptions)
  • func (o *ClientOption) ApplyToPatch(*client.PatchOptions)
  • func (o *ClientOption) ApplyToSubResourceCreate(*client.SubResourceCreateOptions)
  • func (o *ClientOption) ApplyToSubResourceGet(*client.SubResourceGetOptions)
  • func (o *ClientOption) ApplyToSubResourcePatch(*client.SubResourcePatchOptions)
  • func (o *ClientOption) ApplyToSubResourceUpdate(*client.SubResourceUpdateOptions)
  • func (o *ClientOption) ApplyToUpdate(*client.UpdateOptions)
• type Manager
  • func Setup(scheme *runtime.Scheme, cli client.Client, kubeConfig, contexts string) (Manager, error)

Functions

func Assign

func Assign(ctx context.Context, obj client.Object, ordinal func() int) client.Object

func FromContext

func FromContext(ctx context.Context) (string, error)

func IntoContext

func IntoContext(ctx context.Context, placement string) context.Context

func NewClient

func NewClient(control client.Client, workers map[string]client.Client) client.Client

Types

type ClientOption

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

func InControlContext

func InControlContext() *ClientOption

func InDataContext

func InDataContext() *ClientOption

func InDataContextUnspecified

func InDataContextUnspecified() *ClientOption

func InUniversalContext

func InUniversalContext() *ClientOption

func (*ClientOption) ApplyToCreate

func (o *ClientOption) ApplyToCreate(*client.CreateOptions)

func (*ClientOption) ApplyToDelete

func (o *ClientOption) ApplyToDelete(*client.DeleteOptions)

func (*ClientOption) ApplyToDeleteAllOf

func (o *ClientOption) ApplyToDeleteAllOf(*client.DeleteAllOfOptions)

func (*ClientOption) ApplyToGet

func (o *ClientOption) ApplyToGet(*client.GetOptions)

func (*ClientOption) ApplyToList

func (o *ClientOption) ApplyToList(*client.ListOptions)

func (*ClientOption) ApplyToPatch

func (o *ClientOption) ApplyToPatch(*client.PatchOptions)

func (*ClientOption) ApplyToSubResourceCreate

func (o *ClientOption) ApplyToSubResourceCreate(*client.SubResourceCreateOptions)

func (*ClientOption) ApplyToSubResourceGet

func (o *ClientOption) ApplyToSubResourceGet(*client.SubResourceGetOptions)

func (*ClientOption) ApplyToSubResourcePatch

func (o *ClientOption) ApplyToSubResourcePatch(*client.SubResourcePatchOptions)

func (*ClientOption) ApplyToSubResourceUpdate

func (o *ClientOption) ApplyToSubResourceUpdate(*client.SubResourceUpdateOptions)

func (*ClientOption) ApplyToUpdate

func (o *ClientOption) ApplyToUpdate(*client.UpdateOptions)

type Manager

type Manager interface {
	GetClient() client.Client

	GetContexts() []string

	Bind(mgr ctrl.Manager) error

	Own(b *builder.Builder, obj, owner client.Object) Manager

	Watch(b *builder.Builder, obj client.Object, eventHandler handler.EventHandler) Manager
}

func Setup

func Setup(scheme *runtime.Scheme, cli client.Client, kubeConfig, contexts string) (Manager, error)