utils

Documentation

Index

• Variables
• func RelaxedJSONPathExpression(pathExpression string) (string, error)
• type ESImporter
  • func NewESImporter(esClient *elasticsearch.Storage, cluster string, ...) *ESImporter
  • func (e *ESImporter) ImportTo(ctx context.Context, store cache.Store) error
• type ESListerGetter
  • func NewESListerGetter(cluster string, esClient *elasticsearch.Storage, ...) *ESListerGetter
  • func (e *ESListerGetter) GetByKey(key string) (value interface{}, exists bool, err error)
  • func (e *ESListerGetter) ListKeys() []string
• type FieldsSelector
  • func (fs FieldsSelector) Empty() bool
• type Importer
• type JSONPathFields
  • func NewJSONPathFields(jpParser *JSONPathParser, data interface{}) *JSONPathFields
  • func (fs JSONPathFields) Get(fieldPath string) (value string)
  • func (fs JSONPathFields) Has(fieldPath string) (exists bool)
• type JSONPathParser
  • func NewJSONPathParser() *JSONPathParser
  • func (j *JSONPathParser) Parse(path string) (*jsonpath.JSONPath, error)
• type MultiSelectors
  • func (m MultiSelectors) ApplyToList(options *metav1.ListOptions)
  • func (m MultiSelectors) Matches(obj Selectable) bool
  • func (m MultiSelectors) Predicate(obj interface{}) bool
• type Selectable
• type Selector
  • func (s Selector) Matches(obj Selectable) bool
  • func (s Selector) ServerSupported() bool

Variables

var DefaultJSONPathParser = NewJSONPathParser()

Functions

func RelaxedJSONPathExpression

func RelaxedJSONPathExpression(pathExpression string) (string, error)

copied from kubectl

Types

type ESImporter

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

func NewESImporter

func NewESImporter(esClient *elasticsearch.Storage, cluster string, gvr schema.GroupVersionResource) *ESImporter

func (*ESImporter) ImportTo

func (e *ESImporter) ImportTo(ctx context.Context, store cache.Store) error

type ESListerGetter

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

func NewESListerGetter

func NewESListerGetter(cluster string, esClient *elasticsearch.Storage, gvr schema.GroupVersionResource) *ESListerGetter

func (*ESListerGetter) GetByKey

func (e *ESListerGetter) GetByKey(key string) (value interface{}, exists bool, err error)

func (*ESListerGetter) ListKeys

func (e *ESListerGetter) ListKeys() []string

type FieldsSelector

type FieldsSelector struct {
	fields.Selector
	ServerSupported bool
}

func (FieldsSelector) Empty

func (fs FieldsSelector) Empty() bool

type Importer

type Importer interface {
	ImportTo(ctx context.Context, store cache.Store) error
}

type JSONPathFields

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

func NewJSONPathFields

func NewJSONPathFields(jpParser *JSONPathParser, data interface{}) *JSONPathFields

func (JSONPathFields) Get

func (fs JSONPathFields) Get(fieldPath string) (value string)

func (JSONPathFields) Has

func (fs JSONPathFields) Has(fieldPath string) (exists bool)

type JSONPathParser

type JSONPathParser struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewJSONPathParser

func NewJSONPathParser() *JSONPathParser

func (*JSONPathParser) Parse

func (j *JSONPathParser) Parse(path string) (*jsonpath.JSONPath, error)

type MultiSelectors

type MultiSelectors []Selector

func (MultiSelectors) ApplyToList

func (m MultiSelectors) ApplyToList(options *metav1.ListOptions)

func (MultiSelectors) Matches

func (m MultiSelectors) Matches(obj Selectable) bool

func (MultiSelectors) Predicate

func (m MultiSelectors) Predicate(obj interface{}) bool

type Selectable

type Selectable interface {
	GetLabels() labels.Labels
	GetFields() fields.Fields
}

type Selector

type Selector struct {
	Label labels.Selector
	Field FieldsSelector
}

func (Selector) Matches

func (s Selector) Matches(obj Selectable) bool

func (Selector) ServerSupported

func (s Selector) ServerSupported() bool