perisco

Documentation

Index

• func NewMatcher(options ...MatcherOption) (*reqRespMatcher, error)
• func NewParser(options ...ParserOption) (*reqRespParser, error)
• func NewProtoDetecter(pm *maps.ProtocolMap, log *zap.SugaredLogger) *protoDetecter
• type Breaker
• type Enricher
  • func NewEnricher(log *zap.SugaredLogger, store ResourcesStore) (*Enricher, error)
  • func (e *Enricher) Run(ctx context.Context, msgc chan *pb.ProtoMessage) chan *pb.K8SProtoMessage
  • func (e *Enricher) Stop() error
• type MatcherOption
  • func MatcherWithLogger(log *zap.SugaredLogger) MatcherOption
  • func MatcherWithProtocols(protos []types.ProtocolType) MatcherOption
• type ParserOption
  • func ParserWithBreaker(breaker Breaker) ParserOption
  • func ParserWithLogger(log *zap.SugaredLogger) ParserOption
  • func ParserWithProtocols(protos []types.ProtocolType) ParserOption
• type ResourcesStore

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
}