perisco

package
v0.0.0-...-59efaf5 Latest Latest
Warning

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

Go to latest
Published: Oct 24, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMatcher

func NewMatcher(options ...MatcherOption) (*reqRespMatcher, error)

func NewParser

func NewParser(options ...ParserOption) (*reqRespParser, error)

func NewProtoDetecter

func NewProtoDetecter(pm *maps.ProtocolMap, log *zap.SugaredLogger) *protoDetecter

Types

type Breaker

type Breaker interface {
	Success(types.SockKey, types.ProtocolType)
	Fail(types.SockKey)
}

type Enricher

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

func NewEnricher

func NewEnricher(log *zap.SugaredLogger, store ResourcesStore) (*Enricher, error)

func (*Enricher) Run

func (e *Enricher) Run(ctx context.Context, msgc chan *pb.ProtoMessage) chan *pb.K8SProtoMessage

func (*Enricher) Stop

func (e *Enricher) Stop() error

type MatcherOption

type MatcherOption func(o *matcherOptions) error

func MatcherWithLogger

func MatcherWithLogger(log *zap.SugaredLogger) MatcherOption

func MatcherWithProtocols

func MatcherWithProtocols(protos []types.ProtocolType) MatcherOption

type ParserOption

type ParserOption func(o *parserOptions) error

func ParserWithBreaker

func ParserWithBreaker(breaker Breaker) ParserOption

func ParserWithLogger

func ParserWithLogger(log *zap.SugaredLogger) ParserOption

func ParserWithProtocols

func ParserWithProtocols(protos []types.ProtocolType) ParserOption

type ResourcesStore

type ResourcesStore interface {
	GetPodInfo(ip string) *pb.Endpoint
	GetServiceInfo(ip string) *pb.Service
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL