resourceclient

Documentation

Index

• type ApplyOption
• type ApplyOptions
  • func (o *ApplyOptions) ApplyOptions(opts []ApplyOption) *ApplyOptions
  • func (o *ApplyOptions) ApplyToApply(lo *ApplyOptions)
• type Client
  • func NewAPIStorageClient(apistore *api.APIStore) Client
  • func NewClient(config *config.Config) (Client, error)
  • func NewMockClient(storage rest.Storage) Client
• type CreateOption
• type CreateOptions
  • func (o *CreateOptions) ApplyOptions(opts []CreateOption) *CreateOptions
  • func (o *CreateOptions) ApplyToCreate(lo *CreateOptions)
• type DeleteOption
• type DeleteOptions
  • func (o *DeleteOptions) ApplyOptions(opts []DeleteOption) *DeleteOptions
  • func (o *DeleteOptions) ApplyToDelete(lo *DeleteOptions)
• type GetOption
• type GetOptions
  • func (o *GetOptions) ApplyOptions(opts []GetOption) *GetOptions
  • func (o *GetOptions) ApplyToGet(lo *GetOptions)
• type ListOption
• type ListOptions
  • func (o *ListOptions) ApplyOptions(opts []ListOption) *ListOptions
  • func (o *ListOptions) ApplyToList(lo *ListOptions)
• type ResourceClient
  • func NewResourceClient(config *config.Config) (ResourceClient, error)
• type UpdateOption
• type UpdateOptions
  • func (o *UpdateOptions) ApplyOptions(opts []UpdateOption) *UpdateOptions
  • func (o *UpdateOptions) ApplyToUpdate(lo *UpdateOptions)

Types

type ApplyOption

type ApplyOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToApply(*ApplyOptions)
}

type ApplyOptions

type ApplyOptions struct {
	Trace        string
	Origin       string
	DryRun       bool
	FieldManager string
	Force        bool
	Branch       string
	Proxy        types.NamespacedName
}

func (*ApplyOptions) ApplyOptions

func (o *ApplyOptions) ApplyOptions(opts []ApplyOption) *ApplyOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*ApplyOptions) ApplyToApply

func (o *ApplyOptions) ApplyToApply(lo *ApplyOptions)

type Client

type Client interface {
	Get(ctx context.Context, key types.NamespacedName, u runtime.Unstructured, opts ...GetOption) error
	List(ctx context.Context, ul runtime.Unstructured, opts ...ListOption) error
	Apply(ctx context.Context, u runtime.Unstructured, opts ...ApplyOption) error
	Create(ctx context.Context, u runtime.Unstructured, opts ...CreateOption) error
	Update(ctx context.Context, u runtime.Unstructured, opts ...UpdateOption) error
	Delete(ctx context.Context, u runtime.Unstructured, opts ...DeleteOption) error
	Watch(ctx context.Context, u runtime.Unstructured, opts ...ListOption) chan *resourcepb.Watch_Response
	Close() error
}

func NewAPIStorageClient

func NewAPIStorageClient(apistore *api.APIStore) Client

used for api access during api loading

func NewClient

func NewClient(config *config.Config) (Client, error)

func NewMockClient

func NewMockClient(storage rest.Storage) Client

type CreateOption

type CreateOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToCreate(*CreateOptions)
}

type CreateOptions

type CreateOptions struct {
	Trace  string
	Origin string
	DryRun bool
	Branch string
	Proxy  types.NamespacedName
}

func (*CreateOptions) ApplyOptions

func (o *CreateOptions) ApplyOptions(opts []CreateOption) *CreateOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*CreateOptions) ApplyToCreate

func (o *CreateOptions) ApplyToCreate(lo *CreateOptions)

type DeleteOption

type DeleteOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToDelete(*DeleteOptions)
}

type DeleteOptions

type DeleteOptions struct {
	Trace  string
	Origin string
	DryRun bool
	Branch string
	Proxy  types.NamespacedName
}

func (*DeleteOptions) ApplyOptions

func (o *DeleteOptions) ApplyOptions(opts []DeleteOption) *DeleteOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*DeleteOptions) ApplyToDelete

func (o *DeleteOptions) ApplyToDelete(lo *DeleteOptions)

type GetOption

type GetOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToGet(*GetOptions)
}

type GetOptions

type GetOptions struct {
	Proxy             types.NamespacedName
	Branch            string
	Ref               string
	Commit            *object.Commit
	ShowManagedFields bool
	Trace             string
	Origin            string
}

func (*GetOptions) ApplyOptions

func (o *GetOptions) ApplyOptions(opts []GetOption) *GetOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*GetOptions) ApplyToGet

func (o *GetOptions) ApplyToGet(lo *GetOptions)

type ListOption

type ListOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToList(*ListOptions)
}

type ListOptions

type ListOptions struct {
	Proxy             types.NamespacedName
	Branch            string
	Ref               string
	Commit            *object.Commit
	ShowManagedFields bool
	Trace             string
	Origin            string
	// A selector based on expressions
	ExprSelector *resourcepb.ExpressionSelector
	Watch        bool
}

func (*ListOptions) ApplyOptions

func (o *ListOptions) ApplyOptions(opts []ListOption) *ListOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*ListOptions) ApplyToList

func (o *ListOptions) ApplyToList(lo *ListOptions)

type ResourceClient

type ResourceClient interface {
	Get(ctx context.Context, in *resourcepb.Get_Request, opts ...grpc.CallOption) (*resourcepb.Get_Response, error)
	List(ctx context.Context, in *resourcepb.List_Request, opts ...grpc.CallOption) (*resourcepb.List_Response, error)
	Create(ctx context.Context, in *resourcepb.Create_Request, opts ...grpc.CallOption) (*resourcepb.Create_Response, error)
	Update(ctx context.Context, in *resourcepb.Update_Request, opts ...grpc.CallOption) (*resourcepb.Update_Response, error)
	Apply(ctx context.Context, in *resourcepb.Apply_Request, opts ...grpc.CallOption) (*resourcepb.Apply_Response, error)
	Delete(ctx context.Context, in *resourcepb.Delete_Request, opts ...grpc.CallOption) (*resourcepb.Delete_Response, error)
	Watch(ctx context.Context, in *resourcepb.Watch_Request, opts ...grpc.CallOption) chan *resourcepb.Watch_Response
	Close() error
}

func NewResourceClient

func NewResourceClient(config *config.Config) (ResourceClient, error)

type UpdateOption

type UpdateOption interface {
	// ApplyToGet applies this configuration to the given get options.
	ApplyToUpdate(*UpdateOptions)
}

type UpdateOptions

type UpdateOptions struct {
	Trace  string
	Origin string
	DryRun bool
	Branch string
	Proxy  types.NamespacedName
}

func (*UpdateOptions) ApplyOptions

func (o *UpdateOptions) ApplyOptions(opts []UpdateOption) *UpdateOptions

ApplyOptions applies the given get options on these options, and then returns itself (for convenient chaining).

func (*UpdateOptions) ApplyToUpdate

func (o *UpdateOptions) ApplyToUpdate(lo *UpdateOptions)