internal

Documentation

Index

• func GetDefaultIndexName() string
• func IsTypeEnabled(configuredTypes []string, currentType string) bool
• func NewEvent() *beat.Event
• func Publish(publisher stateless.Publisher, baseEvent *beat.Event, opts ...AssetOption)
• func ToMapstr(input map[string]string) mapstr.M
• type AssetOption
  • func WithAssetAccountID(value string) AssetOption
  • func WithAssetChildren(value []string) AssetOption
  • func WithAssetCloudProvider(value string) AssetOption
  • func WithAssetKindAndID(k, id string) AssetOption
  • func WithAssetMetadata(value mapstr.M) AssetOption
  • func WithAssetName(value string) AssetOption
  • func WithAssetParents(value []string) AssetOption
  • func WithAssetRegion(value string) AssetOption
  • func WithAssetType(value string) AssetOption
  • func WithCloudInstanceId(instanceId string) AssetOption
  • func WithContainerData(name, uid, namespace, state string, startTime *metav1.Time) AssetOption
  • func WithNodeData(name string, startTime *metav1.Time) AssetOption
  • func WithPodData(name, uid, namespace string, startTime *metav1.Time) AssetOption
• type BaseConfig

Functions

func GetDefaultIndexName

func GetDefaultIndexName() string

func IsTypeEnabled

func IsTypeEnabled(configuredTypes []string, currentType string) bool

func NewEvent

func NewEvent() *beat.Event

func Publish

func Publish(publisher stateless.Publisher, baseEvent *beat.Event, opts ...AssetOption)

Publish emits a `beat.Event` to the specified publisher, with the provided parameters

func ToMapstr

func ToMapstr(input map[string]string) mapstr.M

Types

type AssetOption

type AssetOption func(beat.Event) beat.Event

func WithAssetAccountID

func WithAssetAccountID(value string) AssetOption

func WithAssetChildren

func WithAssetChildren(value []string) AssetOption

func WithAssetCloudProvider

func WithAssetCloudProvider(value string) AssetOption

func WithAssetKindAndID

func WithAssetKindAndID(k, id string) AssetOption

func WithAssetMetadata

func WithAssetMetadata(value mapstr.M) AssetOption

func WithAssetName

func WithAssetName(value string) AssetOption

func WithAssetParents

func WithAssetParents(value []string) AssetOption

func WithAssetRegion

func WithAssetRegion(value string) AssetOption

func WithAssetType

func WithAssetType(value string) AssetOption

func WithCloudInstanceId

func WithCloudInstanceId(instanceId string) AssetOption

func WithContainerData

func WithContainerData(name, uid, namespace, state string, startTime *metav1.Time) AssetOption

func WithNodeData

func WithNodeData(name string, startTime *metav1.Time) AssetOption

func WithPodData

func WithPodData(name, uid, namespace string, startTime *metav1.Time) AssetOption

type BaseConfig

type BaseConfig struct {
	Period     time.Duration `config:"period"`
	AssetTypes []string      `config:"asset_types"`
}