...

Package provider

import "github.com/chaos-mesh/chaos-mesh/cmd/chaos-controller-manager/provider"
Overview
Index

Overview ▾

Index ▾

Variables
func NewAuthCli(cfg *rest.Config) (*authorizationv1.AuthorizationV1Client, error)
func NewClient(mgr ctrl.Manager, scheme *runtime.Scheme) (client.Client, error)
func NewClientSet(config *rest.Config) (*kubernetes.Clientset, error)
func NewConfig() *rest.Config
func NewControlPlaneCacheReader(logger logr.Logger) (controlPlaneCacheReader, error)
func NewGlobalCacheReader(mgr ctrl.Manager) globalCacheReader
func NewLogger() logr.Logger
func NewManager(options *ctrl.Options, cfg *rest.Config) (ctrl.Manager, error)
func NewNoCacheReader(mgr ctrl.Manager) noCacheReader
func NewOption(logger logr.Logger) *ctrl.Options
func NewScheme() *runtime.Scheme
type UpdatedClient
    func (c *UpdatedClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
    func (c *UpdatedClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
    func (c *UpdatedClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
    func (c *UpdatedClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error
    func (c *UpdatedClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
    func (c *UpdatedClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error
    func (c *UpdatedClient) RESTMapper() meta.RESTMapper
    func (c *UpdatedClient) Scheme() *runtime.Scheme
    func (c *UpdatedClient) Status() client.StatusWriter
    func (c *UpdatedClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
type UpdatedStatusWriter
    func (c *UpdatedStatusWriter) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error
    func (c *UpdatedStatusWriter) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

Package files

controller.go updated_client.go

Variables

var Module = fx.Provide(
    NewOption,
    NewClient,
    NewClientSet,
    NewManager,
    NewLogger,
    NewAuthCli,
    NewScheme,
    NewConfig,
    NewNoCacheReader,
    NewGlobalCacheReader,
    NewControlPlaneCacheReader,
)

func NewAuthCli

func NewAuthCli(cfg *rest.Config) (*authorizationv1.AuthorizationV1Client, error)

func NewClient

func NewClient(mgr ctrl.Manager, scheme *runtime.Scheme) (client.Client, error)

func NewClientSet

func NewClientSet(config *rest.Config) (*kubernetes.Clientset, error)

func NewConfig

func NewConfig() *rest.Config

func NewControlPlaneCacheReader

func NewControlPlaneCacheReader(logger logr.Logger) (controlPlaneCacheReader, error)

func NewGlobalCacheReader

func NewGlobalCacheReader(mgr ctrl.Manager) globalCacheReader

func NewLogger

func NewLogger() logr.Logger

func NewManager

func NewManager(options *ctrl.Options, cfg *rest.Config) (ctrl.Manager, error)

func NewNoCacheReader

func NewNoCacheReader(mgr ctrl.Manager) noCacheReader

func NewOption

func NewOption(logger logr.Logger) *ctrl.Options

func NewScheme

func NewScheme() *runtime.Scheme

type UpdatedClient

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

func (*UpdatedClient) Create

func (c *UpdatedClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*UpdatedClient) Delete

func (c *UpdatedClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*UpdatedClient) DeleteAllOf

func (c *UpdatedClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*UpdatedClient) Get

func (c *UpdatedClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

func (*UpdatedClient) List

func (c *UpdatedClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*UpdatedClient) Patch

func (c *UpdatedClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*UpdatedClient) RESTMapper

func (c *UpdatedClient) RESTMapper() meta.RESTMapper

func (*UpdatedClient) Scheme

func (c *UpdatedClient) Scheme() *runtime.Scheme

func (*UpdatedClient) Status

func (c *UpdatedClient) Status() client.StatusWriter

func (*UpdatedClient) Update

func (c *UpdatedClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type UpdatedStatusWriter

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

func (*UpdatedStatusWriter) Patch

func (c *UpdatedStatusWriter) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*UpdatedStatusWriter) Update

func (c *UpdatedStatusWriter) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error