Documentation
¶
Index ¶
- func GenK8sObjects() []runtime.Object
- func NewFakeDumpIngestorPipeline(ctx context.Context, t *testing.T, mockCollector bool) (*mockwriter.DumperWriter, collector.CollectorClient)
- func PipelineLiveTest(ctx context.Context, t *testing.T, workerNum int) (*mockwriter.DumperWriter, collector.CollectorClient)
- type ClusterRoleBindingIngestor
- type ClusterRoleIngestor
- type DumpIngestorPipeline
- type EndpointIngestor
- type NodeIngestor
- type PipelineDumpIngestor
- type PodIngestor
- type RoleBindingIngestor
- type RoleIngestor
- type StreamFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenK8sObjects ¶
func NewFakeDumpIngestorPipeline ¶
func NewFakeDumpIngestorPipeline(ctx context.Context, t *testing.T, mockCollector bool) (*mockwriter.DumperWriter, collector.CollectorClient)
func PipelineLiveTest ¶
func PipelineLiveTest(ctx context.Context, t *testing.T, workerNum int) (*mockwriter.DumperWriter, collector.CollectorClient)
Types ¶
type ClusterRoleBindingIngestor ¶
type ClusterRoleBindingIngestor struct {
// contains filtered or unexported fields
}
func NewClusterRoleBindingIngestor ¶
func NewClusterRoleBindingIngestor(ctx context.Context, dumpWriter writer.DumperWriter) *ClusterRoleBindingIngestor
func (*ClusterRoleBindingIngestor) Complete ¶
func (d *ClusterRoleBindingIngestor) Complete(ctx context.Context) error
Complete() is invoked by the collector when all k8s assets have been streamed. The function flushes all writers and waits for completion.
func (*ClusterRoleBindingIngestor) IngestClusterRoleBinding ¶
func (d *ClusterRoleBindingIngestor) IngestClusterRoleBinding(ctx context.Context, clusterRoleBinding types.ClusterRoleBindingType) error
type ClusterRoleIngestor ¶
type ClusterRoleIngestor struct {
// contains filtered or unexported fields
}
func NewClusterRoleIngestor ¶
func NewClusterRoleIngestor(ctx context.Context, dumpWriter writer.DumperWriter) *ClusterRoleIngestor
func (*ClusterRoleIngestor) Complete ¶
func (d *ClusterRoleIngestor) Complete(ctx context.Context) error
Complete() is invoked by the collector when all k8s assets have been streamed. The function flushes all writers and waits for completion.
func (*ClusterRoleIngestor) IngestClusterRole ¶
func (d *ClusterRoleIngestor) IngestClusterRole(ctx context.Context, clusterRole types.ClusterRoleType) error
type DumpIngestorPipeline ¶
type DumpIngestorPipeline struct {
// contains filtered or unexported fields
}
type EndpointIngestor ¶
type EndpointIngestor struct {
// contains filtered or unexported fields
}
func NewEndpointIngestor ¶
func NewEndpointIngestor(ctx context.Context, dumpWriter writer.DumperWriter) *EndpointIngestor
func (*EndpointIngestor) Complete ¶
func (d *EndpointIngestor) Complete(ctx context.Context) error
Complete() is invoked by the collector when all k8s assets have been streamed. The function flushes all writers and waits for completion.
func (*EndpointIngestor) IngestEndpoint ¶
func (d *EndpointIngestor) IngestEndpoint(ctx context.Context, endpoint types.EndpointType) error
type NodeIngestor ¶
type NodeIngestor struct {
// contains filtered or unexported fields
}
func NewNodeIngestor ¶
func NewNodeIngestor(ctx context.Context, dumpWriter writer.DumperWriter) *NodeIngestor
func (*NodeIngestor) Complete ¶
func (d *NodeIngestor) Complete(ctx context.Context) error
Complete() is invoked by the collector when all k8s assets have been streamed. The function flushes all writers and waits for completion.
func (*NodeIngestor) IngestNode ¶
type PipelineDumpIngestor ¶
type PipelineDumpIngestor struct {
WorkerNumber int
// contains filtered or unexported fields
}
PipelineDumpIngestor is a parallelized pipeline based ingestor implementation.
func NewPipelineDumpIngestor ¶
func NewPipelineDumpIngestor(ctx context.Context, collector collector.CollectorClient, writer writer.DumperWriter) (context.Context, *PipelineDumpIngestor, error)
type PodIngestor ¶
type PodIngestor struct {
// contains filtered or unexported fields
}
func NewPodIngestor ¶
func NewPodIngestor(ctx context.Context, dumpWriter writer.DumperWriter) *PodIngestor
type RoleBindingIngestor ¶
type RoleBindingIngestor struct {
// contains filtered or unexported fields
}
func NewRoleBindingIngestor ¶
func NewRoleBindingIngestor(ctx context.Context, dumpWriter writer.DumperWriter) *RoleBindingIngestor
func (*RoleBindingIngestor) Complete ¶
func (d *RoleBindingIngestor) Complete(ctx context.Context) error
Complete() is invoked by the collector when all k8s assets have been streamed. The function flushes all writers and waits for completion.
func (*RoleBindingIngestor) IngestRoleBinding ¶
func (d *RoleBindingIngestor) IngestRoleBinding(ctx context.Context, roleBinding types.RoleBindingType) error
type RoleIngestor ¶
type RoleIngestor struct {
// contains filtered or unexported fields
}
func NewRoleIngestor ¶
func NewRoleIngestor(ctx context.Context, dumpWriter writer.DumperWriter) *RoleIngestor
func (*RoleIngestor) Complete ¶
func (d *RoleIngestor) Complete(ctx context.Context) error
Complete() is invoked by the collector when all k8s assets have been streamed. The function flushes all writers and waits for completion.
func (*RoleIngestor) IngestRole ¶
type StreamFunc ¶
Source Files
Click to show internal directories.
Click to hide internal directories.