adapter

package
v3.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 6, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFlowProbeFeatureDescriptor 

func NewFlowProbeFeatureDescriptor(typedDescriptor *FlowProbeFeatureDescriptor) *KVDescriptor

func NewFlowProbeParamsDescriptor 

func NewFlowProbeParamsDescriptor(typedDescriptor *FlowProbeParamsDescriptor) *KVDescriptor

func NewIPFIXDescriptor 

func NewIPFIXDescriptor(typedDescriptor *IPFIXDescriptor) *KVDescriptor

Types

type FlowProbeFeatureDescriptor 

type FlowProbeFeatureDescriptor struct {
	Name                 string
	KeySelector          KeySelector
	ValueTypeName        string
	KeyLabel             func(key string) string
	ValueComparator      func(key string, oldValue, newValue *vpp_ipfix.FlowProbeFeature) bool
	NBKeyPrefix          string
	WithMetadata         bool
	MetadataMapFactory   MetadataMapFactory
	Validate             func(key string, value *vpp_ipfix.FlowProbeFeature) error
	Create               func(key string, value *vpp_ipfix.FlowProbeFeature) (metadata interface{}, err error)
	Delete               func(key string, value *vpp_ipfix.FlowProbeFeature, metadata interface{}) error
	Update               func(key string, oldValue, newValue *vpp_ipfix.FlowProbeFeature, oldMetadata interface{}) (newMetadata interface{}, err error)
	UpdateWithRecreate   func(key string, oldValue, newValue *vpp_ipfix.FlowProbeFeature, metadata interface{}) bool
	Retrieve             func(correlate []FlowProbeFeatureKVWithMetadata) ([]FlowProbeFeatureKVWithMetadata, error)
	IsRetriableFailure   func(err error) bool
	DerivedValues        func(key string, value *vpp_ipfix.FlowProbeFeature) []KeyValuePair
	Dependencies         func(key string, value *vpp_ipfix.FlowProbeFeature) []Dependency
	RetrieveDependencies []string /* descriptor name */
}

type FlowProbeFeatureDescriptorAdapter 

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

func (*FlowProbeFeatureDescriptorAdapter) Create 

func (da *FlowProbeFeatureDescriptorAdapter) Create(key string, value proto.Message) (metadata Metadata, err error)

func (*FlowProbeFeatureDescriptorAdapter) Delete 

func (da *FlowProbeFeatureDescriptorAdapter) Delete(key string, value proto.Message, metadata Metadata) error

func (*FlowProbeFeatureDescriptorAdapter) Dependencies 

func (da *FlowProbeFeatureDescriptorAdapter) Dependencies(key string, value proto.Message) []Dependency

func (*FlowProbeFeatureDescriptorAdapter) DerivedValues 

func (da *FlowProbeFeatureDescriptorAdapter) DerivedValues(key string, value proto.Message) []KeyValuePair

func (*FlowProbeFeatureDescriptorAdapter) Retrieve 

func (da *FlowProbeFeatureDescriptorAdapter) Retrieve(correlate []KVWithMetadata) ([]KVWithMetadata, error)

func (*FlowProbeFeatureDescriptorAdapter) Update 

func (da *FlowProbeFeatureDescriptorAdapter) Update(key string, oldValue, newValue proto.Message, oldMetadata Metadata) (newMetadata Metadata, err error)

func (*FlowProbeFeatureDescriptorAdapter) UpdateWithRecreate 

func (da *FlowProbeFeatureDescriptorAdapter) UpdateWithRecreate(key string, oldValue, newValue proto.Message, metadata Metadata) bool

func (*FlowProbeFeatureDescriptorAdapter) Validate 

func (da *FlowProbeFeatureDescriptorAdapter) Validate(key string, value proto.Message) (err error)

func (*FlowProbeFeatureDescriptorAdapter) ValueComparator 

func (da *FlowProbeFeatureDescriptorAdapter) ValueComparator(key string, oldValue, newValue proto.Message) bool

type FlowProbeFeatureKVWithMetadata 

type FlowProbeFeatureKVWithMetadata struct {
	Key      string
	Value    *vpp_ipfix.FlowProbeFeature
	Metadata interface{}
	Origin   ValueOrigin
}

type FlowProbeParamsDescriptor 

type FlowProbeParamsDescriptor struct {
	Name                 string
	KeySelector          KeySelector
	ValueTypeName        string
	KeyLabel             func(key string) string
	ValueComparator      func(key string, oldValue, newValue *vpp_ipfix.FlowProbeParams) bool
	NBKeyPrefix          string
	WithMetadata         bool
	MetadataMapFactory   MetadataMapFactory
	Validate             func(key string, value *vpp_ipfix.FlowProbeParams) error
	Create               func(key string, value *vpp_ipfix.FlowProbeParams) (metadata interface{}, err error)
	Delete               func(key string, value *vpp_ipfix.FlowProbeParams, metadata interface{}) error
	Update               func(key string, oldValue, newValue *vpp_ipfix.FlowProbeParams, oldMetadata interface{}) (newMetadata interface{}, err error)
	UpdateWithRecreate   func(key string, oldValue, newValue *vpp_ipfix.FlowProbeParams, metadata interface{}) bool
	Retrieve             func(correlate []FlowProbeParamsKVWithMetadata) ([]FlowProbeParamsKVWithMetadata, error)
	IsRetriableFailure   func(err error) bool
	DerivedValues        func(key string, value *vpp_ipfix.FlowProbeParams) []KeyValuePair
	Dependencies         func(key string, value *vpp_ipfix.FlowProbeParams) []Dependency
	RetrieveDependencies []string /* descriptor name */
}

type FlowProbeParamsDescriptorAdapter 

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

func (*FlowProbeParamsDescriptorAdapter) Create 

func (da *FlowProbeParamsDescriptorAdapter) Create(key string, value proto.Message) (metadata Metadata, err error)

func (*FlowProbeParamsDescriptorAdapter) Delete 

func (da *FlowProbeParamsDescriptorAdapter) Delete(key string, value proto.Message, metadata Metadata) error

func (*FlowProbeParamsDescriptorAdapter) Dependencies 

func (da *FlowProbeParamsDescriptorAdapter) Dependencies(key string, value proto.Message) []Dependency

func (*FlowProbeParamsDescriptorAdapter) DerivedValues 

func (da *FlowProbeParamsDescriptorAdapter) DerivedValues(key string, value proto.Message) []KeyValuePair

func (*FlowProbeParamsDescriptorAdapter) Retrieve 

func (da *FlowProbeParamsDescriptorAdapter) Retrieve(correlate []KVWithMetadata) ([]KVWithMetadata, error)

func (*FlowProbeParamsDescriptorAdapter) Update 

func (da *FlowProbeParamsDescriptorAdapter) Update(key string, oldValue, newValue proto.Message, oldMetadata Metadata) (newMetadata Metadata, err error)

func (*FlowProbeParamsDescriptorAdapter) UpdateWithRecreate 

func (da *FlowProbeParamsDescriptorAdapter) UpdateWithRecreate(key string, oldValue, newValue proto.Message, metadata Metadata) bool

func (*FlowProbeParamsDescriptorAdapter) Validate 

func (da *FlowProbeParamsDescriptorAdapter) Validate(key string, value proto.Message) (err error)

func (*FlowProbeParamsDescriptorAdapter) ValueComparator 

func (da *FlowProbeParamsDescriptorAdapter) ValueComparator(key string, oldValue, newValue proto.Message) bool

type FlowProbeParamsKVWithMetadata 

type FlowProbeParamsKVWithMetadata struct {
	Key      string
	Value    *vpp_ipfix.FlowProbeParams
	Metadata interface{}
	Origin   ValueOrigin
}

type IPFIXDescriptor 

type IPFIXDescriptor struct {
	Name                 string
	KeySelector          KeySelector
	ValueTypeName        string
	KeyLabel             func(key string) string
	ValueComparator      func(key string, oldValue, newValue *vpp_ipfix.IPFIX) bool
	NBKeyPrefix          string
	WithMetadata         bool
	MetadataMapFactory   MetadataMapFactory
	Validate             func(key string, value *vpp_ipfix.IPFIX) error
	Create               func(key string, value *vpp_ipfix.IPFIX) (metadata interface{}, err error)
	Delete               func(key string, value *vpp_ipfix.IPFIX, metadata interface{}) error
	Update               func(key string, oldValue, newValue *vpp_ipfix.IPFIX, oldMetadata interface{}) (newMetadata interface{}, err error)
	UpdateWithRecreate   func(key string, oldValue, newValue *vpp_ipfix.IPFIX, metadata interface{}) bool
	Retrieve             func(correlate []IPFIXKVWithMetadata) ([]IPFIXKVWithMetadata, error)
	IsRetriableFailure   func(err error) bool
	DerivedValues        func(key string, value *vpp_ipfix.IPFIX) []KeyValuePair
	Dependencies         func(key string, value *vpp_ipfix.IPFIX) []Dependency
	RetrieveDependencies []string /* descriptor name */
}

type IPFIXDescriptorAdapter 

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

func (*IPFIXDescriptorAdapter) Create 

func (da *IPFIXDescriptorAdapter) Create(key string, value proto.Message) (metadata Metadata, err error)

func (*IPFIXDescriptorAdapter) Delete 

func (da *IPFIXDescriptorAdapter) Delete(key string, value proto.Message, metadata Metadata) error

func (*IPFIXDescriptorAdapter) Dependencies 

func (da *IPFIXDescriptorAdapter) Dependencies(key string, value proto.Message) []Dependency

func (*IPFIXDescriptorAdapter) DerivedValues 

func (da *IPFIXDescriptorAdapter) DerivedValues(key string, value proto.Message) []KeyValuePair

func (*IPFIXDescriptorAdapter) Retrieve 

func (da *IPFIXDescriptorAdapter) Retrieve(correlate []KVWithMetadata) ([]KVWithMetadata, error)

func (*IPFIXDescriptorAdapter) Update 

func (da *IPFIXDescriptorAdapter) Update(key string, oldValue, newValue proto.Message, oldMetadata Metadata) (newMetadata Metadata, err error)

func (*IPFIXDescriptorAdapter) UpdateWithRecreate 

func (da *IPFIXDescriptorAdapter) UpdateWithRecreate(key string, oldValue, newValue proto.Message, metadata Metadata) bool

func (*IPFIXDescriptorAdapter) Validate 

func (da *IPFIXDescriptorAdapter) Validate(key string, value proto.Message) (err error)

func (*IPFIXDescriptorAdapter) ValueComparator 

func (da *IPFIXDescriptorAdapter) ValueComparator(key string, oldValue, newValue proto.Message) bool

type IPFIXKVWithMetadata 

type IPFIXKVWithMetadata struct {
	Key      string
	Value    *vpp_ipfix.IPFIX
	Metadata interface{}
	Origin   ValueOrigin
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.