misc

Documentation

Index

• Constants
• Variables
• func BuildPcapFilename(id int64) string
• func BuildUdpPcapFilename(id int64) string
• func Contains(s []string, str string) bool
• func GetContextDataPath(context string) string
• func GetContextPath(context string) string
• func GetDataDir() string
• func GetDataPath(path string) string
• func GetFileContentType(out *os.File) (string, error)
• func GetMasterPcapPath() string
• func GetMasterPcapSizeLimit() int64
• func GetNameResolutionHistoryPath() string
• func GetPcapPath(filename string, context string) string
• func GetPcapsDir() string
• func GetSelfHost() string
• func GetSelfNode() string
• func HandleError(c *gin.Context, err error)
• func InitDataDir()
• func IsTls(id string) bool
• func MergeByteChannels(cs ...<-chan []byte) <-chan []byte
• func RemoveDataDir(path string) string
• func RemovePortFromWorkerHost(workerHost string) string
• func SetMasterPcapSizeLimit(limit int64)
• func SetSelfHost(v string)
• func SetSelfNode(v string)
• type Opts

Constants

const (
	ItemChannelBufferSize     = 100
	PacketChannelBufferSize   = 1000
	ErrorChannelBufferSize    = 100
	LogChannelBufferSize      = 100
	TlsCloseChannelBufferSize = 100
)

const ClientHelloBasicPacket string = "" /* 1166-byte string literal not displayed */

const DefaultContext string = "master"

const MasterPcapSizeCheckPeriod time.Duration = 5 * time.Second

const NameResolutionDumpPeriod time.Duration = 3 * time.Second

const NameResolutionHistoryFilename string = "name_resolution_history.json"

const PcapTTL time.Duration = 10 * time.Second

Variables

var RunID int64

var Snaplen int = 65536

var TargetedPods []v1.Pod // global

Functions

func BuildPcapFilename

func BuildPcapFilename(id int64) string

func BuildUdpPcapFilename

func BuildUdpPcapFilename(id int64) string

func Contains

func Contains(s []string, str string) bool

func GetContextDataPath

func GetContextDataPath(context string) string

func GetContextPath

func GetContextPath(context string) string

func GetDataDir

func GetDataDir() string

func GetDataPath

func GetDataPath(path string) string

func GetFileContentType

func GetFileContentType(out *os.File) (string, error)

func GetMasterPcapPath

func GetMasterPcapPath() string

func GetMasterPcapSizeLimit

func GetMasterPcapSizeLimit() int64

func GetNameResolutionHistoryPath

func GetNameResolutionHistoryPath() string

func GetPcapPath

func GetPcapPath(filename string, context string) string

func GetPcapsDir

func GetPcapsDir() string

func GetSelfHost

func GetSelfHost() string

func GetSelfNode

func GetSelfNode() string

func HandleError

func HandleError(c *gin.Context, err error)

func InitDataDir

func InitDataDir()

func IsTls

func IsTls(id string) bool

func MergeByteChannels

func MergeByteChannels(cs ...<-chan []byte) <-chan []byte

func RemoveDataDir

func RemoveDataDir(path string) string

func RemovePortFromWorkerHost

func RemovePortFromWorkerHost(workerHost string) string

func SetMasterPcapSizeLimit

func SetMasterPcapSizeLimit(limit int64)

func SetSelfHost

func SetSelfHost(v string)

func SetSelfNode

func SetSelfNode(v string)

Types

type Opts

type Opts struct {
	ClusterMode            bool
	StaleConnectionTimeout time.Duration
}