Documentation
¶
Overview ¶
This package provides a Tetragon gRPC client multiplexer and an RPCChecker that wraps a MultiEventChecker and uses the gRPC multiplexer to get a stream of events from all Tetragon pods.
Index ¶
- type RPCChecker
- func (rc *RPCChecker) Check(connTimeout time.Duration) features.Func
- func (rc *RPCChecker) CheckInNamespace(connTimeout time.Duration, namespaces ...string) features.Func
- func (rc *RPCChecker) CheckWithFilters(connTimeout time.Duration, allowList, denyList []*tetragon.Filter) features.Func
- func (rc *RPCChecker) CheckerYaml() (string, error)
- func (rc *RPCChecker) Logs() []byte
- func (rc *RPCChecker) Name() string
- func (rc *RPCChecker) ResetEventCount()
- func (rc *RPCChecker) ResetTimeout()
- func (rc *RPCChecker) Wait(waitTimeout time.Duration) features.Func
- func (rc *RPCChecker) WithEventLimit(limit uint32) *RPCChecker
- func (rc *RPCChecker) WithTimeLimit(limit time.Duration) *RPCChecker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RPCChecker ¶
type RPCChecker struct {
// contains filtered or unexported fields
}
RPCChecker checks gRPC events from one or more events streams.
func NewRPCChecker ¶
func NewRPCChecker(checker ec.MultiEventChecker, name string) *RPCChecker
NewRPCChecker constructs a new RPCChecker from a MultiEventChecker.
func (*RPCChecker) Check ¶
func (rc *RPCChecker) Check(connTimeout time.Duration) features.Func
Check returns a feature func that runs event checks.
func (*RPCChecker) CheckInNamespace ¶
func (rc *RPCChecker) CheckInNamespace(connTimeout time.Duration, namespaces ...string) features.Func
CheckInNamespace returns a feature func that runs event checks on events filtered by one or more k8s namespaces.
func (*RPCChecker) CheckWithFilters ¶
func (rc *RPCChecker) CheckWithFilters(connTimeout time.Duration, allowList, denyList []*tetragon.Filter) features.Func
CheckInNamespace returns a feature func that runs event checks on events filtered by one or more filters.
func (*RPCChecker) CheckerYaml ¶
func (rc *RPCChecker) CheckerYaml() (string, error)
CheckerYaml dumps the inner checker's yaml definition
func (*RPCChecker) Logs ¶
func (rc *RPCChecker) Logs() []byte
func (*RPCChecker) ResetEventCount ¶
func (rc *RPCChecker) ResetEventCount()
func (*RPCChecker) ResetTimeout ¶
func (rc *RPCChecker) ResetTimeout()
func (*RPCChecker) Wait ¶
func (rc *RPCChecker) Wait(waitTimeout time.Duration) features.Func
Wait returns a features.Func that waits for the checker to have started its checks or fails the test on timeout.
func (*RPCChecker) WithEventLimit ¶
func (rc *RPCChecker) WithEventLimit(limit uint32) *RPCChecker
WithEventLimit sets the event limit for an RPCChecker. If RPCChecker.Check sees more events than the limit, it returns an error.
func (*RPCChecker) WithTimeLimit ¶
func (rc *RPCChecker) WithTimeLimit(limit time.Duration) *RPCChecker
WithTimeLimit sets the time limit for an RPCChecker. RPCChecker.Check takes longer than the time limit, it returns an error.
Source Files