testutils

package

Go to main page

Versions in this module

v0

v0.5.2

Jul 22, 2020 GO-2025-3700

GO-2025-3700: Character injection in Hubble CLI in github.com/cilium/hubble

v0.5.1

Apr 15, 2020 GO-2025-3700

GO-2025-3700: Character injection in Hubble CLI in github.com/cilium/hubble

v0.5.0

Mar 23, 2020 GO-2025-3700

GO-2025-3700: Character injection in Hubble CLI in github.com/cilium/hubble

Changes in this version

+ var NoopDNSGetter = FakeFQDNCache

+ var NoopEndpointGetter = FakeEndpointGetter

+ var NoopIPGetter = FakeIPGetter

+ var NoopIdentityGetter = FakeIdentityGetter

+ var NoopServiceGetter = FakeServiceGetter

+ func CreateL3L4Payload(message interface{}, layers ...gopacket.SerializableLayer) ([]byte, error)

+ func MustCreateL3L4Payload(message interface{}, layers ...gopacket.SerializableLayer) []byte

+ type FakeCiliumClient struct

+ FakeEndpointList func() ([]*models.Endpoint, error)

+ FakeGetEndpoint func(uint64) (*models.Endpoint, error)

+ FakeGetFqdnCache func() ([]*models.DNSLookup, error)

+ FakeGetIPCache func() ([]*models.IPListEntry, error)

+ FakeGetIdentity func(uint64) (*models.Identity, error)

+ FakeGetServiceCache func() ([]*models.Service, error)

+ func (c *FakeCiliumClient) EndpointList() ([]*models.Endpoint, error)

+ func (c *FakeCiliumClient) GetEndpoint(id uint64) (*models.Endpoint, error)

+ func (c *FakeCiliumClient) GetFqdnCache() ([]*models.DNSLookup, error)

+ func (c *FakeCiliumClient) GetIPCache() ([]*models.IPListEntry, error)

+ func (c *FakeCiliumClient) GetIdentity(id uint64) (*models.Identity, error)

+ func (c *FakeCiliumClient) GetServiceCache() ([]*models.Service, error)

+ type FakeEndpointGetter struct

+ OnGetEndpointInfo func(ip net.IP) (endpoint v1.EndpointInfo, ok bool)

+ func (f *FakeEndpointGetter) GetEndpointInfo(ip net.IP) (endpoint v1.EndpointInfo, ok bool)

+ type FakeEndpointsHandler struct

+ FakeDeleteEndpoint func(*v1.Endpoint)

+ FakeFindEPs func(epID uint64, ns, pod string) []v1.Endpoint

+ FakeGetEndpoint func(ip net.IP) (endpoint *v1.Endpoint, ok bool)

+ FakeGetEndpointByContainerID func(id string) (endpoint *v1.Endpoint, ok bool)

+ FakeGetEndpointByPodName func(namespace string, name string) (*v1.Endpoint, bool)

+ FakeSyncEndpoints func([]*v1.Endpoint)

+ FakeUpdateEndpoint func(*v1.Endpoint)

+ func (f *FakeEndpointsHandler) DeleteEndpoint(ep *v1.Endpoint)

+ func (f *FakeEndpointsHandler) FindEPs(epID uint64, ns, pod string) []v1.Endpoint

+ func (f *FakeEndpointsHandler) GetEndpoint(ip net.IP) (ep *v1.Endpoint, ok bool)

+ func (f *FakeEndpointsHandler) GetEndpointByContainerID(id string) (ep *v1.Endpoint, ok bool)

+ func (f *FakeEndpointsHandler) GetEndpointByPodName(namespace string, name string) (ep *v1.Endpoint, ok bool)

+ func (f *FakeEndpointsHandler) SyncEndpoints(eps []*v1.Endpoint)

+ func (f *FakeEndpointsHandler) UpdateEndpoint(ep *v1.Endpoint)

+ type FakeFQDNCache struct

+ OnAddDNSLookup func(epID uint64, lookupTime time.Time, domainName string, ips []net.IP, ttl uint32)

+ OnGetNamesOf func(epID uint64, ip net.IP) []string

+ OnInitializeFrom func(entries []*models.DNSLookup)

+ func (f *FakeFQDNCache) AddDNSLookup(epID uint64, lookupTime time.Time, domainName string, ips []net.IP, ttl uint32)

+ func (f *FakeFQDNCache) GetNamesOf(epID uint64, ip net.IP) []string

+ func (f *FakeFQDNCache) InitializeFrom(entries []*models.DNSLookup)

+ type FakeFlow struct

+ Destination *pb.Endpoint

+ DestinationNames []string

+ DestinationService *pb.Service

+ DropReason uint32

+ Ethernet *pb.Ethernet

+ EventType *pb.CiliumEventType

+ IP *pb.IP

+ L4 *pb.Layer4

+ L7 *pb.Layer7

+ NodeName string

+ Reply bool

+ Source *pb.Endpoint

+ SourceNames []string

+ SourceService *pb.Service

+ Time *types.Timestamp

+ Type pb.FlowType

+ Verdict pb.Verdict

+ func (f *FakeFlow) GetDestination() *pb.Endpoint

+ func (f *FakeFlow) GetDestinationNames() []string

+ func (f *FakeFlow) GetDestinationService() *pb.Service

+ func (f *FakeFlow) GetDropReason() uint32

+ func (f *FakeFlow) GetEthernet() *pb.Ethernet

+ func (f *FakeFlow) GetEventType() *pb.CiliumEventType

+ func (f *FakeFlow) GetIP() *pb.IP

+ func (f *FakeFlow) GetL4() *pb.Layer4

+ func (f *FakeFlow) GetL7() *pb.Layer7

+ func (f *FakeFlow) GetNodeName() string

+ func (f *FakeFlow) GetReply() bool

+ func (f *FakeFlow) GetSource() *pb.Endpoint

+ func (f *FakeFlow) GetSourceNames() []string

+ func (f *FakeFlow) GetSourceService() *pb.Service

+ func (f *FakeFlow) GetSummary() string

+ func (f *FakeFlow) GetTime() *types.Timestamp

+ func (f *FakeFlow) GetType() pb.FlowType

+ func (f *FakeFlow) GetVerdict() pb.Verdict

+ func (f *FakeFlow) ProtoMessage()

+ func (f *FakeFlow) Reset()

+ func (f *FakeFlow) String() string

+ type FakeIPGetter struct

+ OnGetIPIdentity func(ip net.IP) (id ipcache.IPIdentity, ok bool)

+ func (f *FakeIPGetter) GetIPIdentity(ip net.IP) (id ipcache.IPIdentity, ok bool)

+ type FakeIdentityGetter struct

+ OnGetIdentity func(securityIdentity uint64) (*models.Identity, error)

+ func (f *FakeIdentityGetter) GetIdentity(securityIdentity uint64) (*models.Identity, error)

+ type FakeServiceGetter struct

+ OnGetServiceByAddr func(ip net.IP, port uint16) (service pb.Service, ok bool)

+ func (f *FakeServiceGetter) GetServiceByAddr(ip net.IP, port uint16) (service pb.Service, ok bool)

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