hooks

Documentation

Index

• func BuildCustomPacketInfo(packet gopacket.Packet, fragmented bool) (info map[string]interface{}, err error)
• func IsMissingHookError(err error, hook string) bool
• func MarshalUnmarshalEntry(entry *api.Entry) (result map[string]interface{}, err error)
• func MarshalUnmarshalEntryReverse(result map[string]interface{}) (entry *api.Entry, err error)
• type CustomPacketInfo
• type Hooks
  • func (h Hooks) ContainerStatusChangeHook(index int, status *v1.ContainerStatus, pod *v1.Pod)
  • func (h Hooks) ItemCapturedHook(entry *api.Entry)
  • func (h Hooks) ItemQueriedHook(entry *api.Entry, filter string) *api.Entry
  • func (h Hooks) JobFailedHook(tag string, cron string, limit int64, err string)
  • func (h Hooks) JobPassedHook(tag string, cron string, limit int64)
  • func (h Hooks) PacketCapturedHook(packet gopacket.Packet, fragmented bool)
  • func (h Hooks) PodEventHook(eventType watch.EventType, pod *v1.Pod)

Functions

func BuildCustomPacketInfo

func BuildCustomPacketInfo(packet gopacket.Packet, fragmented bool) (info map[string]interface{}, err error)

func IsMissingHookError

func IsMissingHookError(err error, hook string) bool

func MarshalUnmarshalEntry

func MarshalUnmarshalEntry(entry *api.Entry) (result map[string]interface{}, err error)

func MarshalUnmarshalEntryReverse

func MarshalUnmarshalEntryReverse(result map[string]interface{}) (entry *api.Entry, err error)

Types

type CustomPacketInfo

type CustomPacketInfo struct {
	Timestamp     time.Time `json:"timestamp"`
	CaptureLength int       `json:"captureLength"`
	Length        int       `json:"length"`
	Truncated     bool      `json:"truncated"`
	Fragmented    bool      `json:"fragmented"`
}

type Hooks

type Hooks struct{}

func (Hooks) ContainerStatusChangeHook

func (h Hooks) ContainerStatusChangeHook(index int, status *v1.ContainerStatus, pod *v1.Pod)

Hook: onContainerStatusChange, does not accept returns

func (Hooks) ItemCapturedHook

func (h Hooks) ItemCapturedHook(entry *api.Entry)

Hook: onItemCaptured, does not accept returns

func (Hooks) ItemQueriedHook

func (h Hooks) ItemQueriedHook(entry *api.Entry, filter string) *api.Entry

Hook: onItemQueried, accepts Object type returns

func (Hooks) JobFailedHook

func (h Hooks) JobFailedHook(tag string, cron string, limit int64, err string)

Hook: onJobFailed, does not accept returns

func (Hooks) JobPassedHook

func (h Hooks) JobPassedHook(tag string, cron string, limit int64)

Hook: onJobPassed, does not accept returns

func (Hooks) PacketCapturedHook

func (h Hooks) PacketCapturedHook(packet gopacket.Packet, fragmented bool)

Hook: onPacketCaptured, does not accept returns

func (Hooks) PodEventHook

func (h Hooks) PodEventHook(eventType watch.EventType, pod *v1.Pod)

Hook: onPodEvent, does not accept returns