scraper

Documentation

Index

• type ClientFactory
  • func (f *ClientFactory) Client(ctx context.Context, url string) (DiscoveryClient, func() error, error)
• type DiscoveryClient
• type DiscoveryFactory
• type Job
  • func NewJob(podLister PodLister, discoveryFactory DiscoveryFactory) *Job
  • func (j *Job) GetKafmeshPods(ctx context.Context) ([]v1.Pod, error)
  • func (j *Job) ScrapePod(ctx context.Context, pod v1.Pod) (*discoveryv1.Service, error)
• type PodLister

Types

type ClientFactory

type ClientFactory struct{}

ClientFactory generates DiscoveryClients for a pod

func (*ClientFactory) Client

func (f *ClientFactory) Client(ctx context.Context, url string) (DiscoveryClient, func() error, error)

Client gets a Discovery client for an address

type DiscoveryClient

type DiscoveryClient interface {
	GetServiceInfo(context.Context, *discoveryv1.GetServiceInfoRequest, ...grpc.CallOption) (*discoveryv1.GetServiceInfoResponse, error)
}

DiscoveryClient is the kafmesh discovery grpc client

type DiscoveryFactory

type DiscoveryFactory interface {
	Client(context.Context, string) (DiscoveryClient, func() error, error)
}

DiscoveryFactory creates DiscoveryClients for pods

type Job

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

Job runs scrape jobs against pods running in the cluster

func NewJob

func NewJob(podLister PodLister, discoveryFactory DiscoveryFactory) *Job

NewJob creates a new job

func (*Job) GetKafmeshPods

func (j *Job) GetKafmeshPods(ctx context.Context) ([]v1.Pod, error)

GetKafmeshPods gets all kafmesh pods running in the cluster

func (*Job) ScrapePod

func (j *Job) ScrapePod(ctx context.Context, pod v1.Pod) (*discoveryv1.Service, error)

ScrapePod gets the kafmesh service info from the pod

type PodLister

type PodLister interface {
	List(context.Context, metav1.ListOptions) (*v1.PodList, error)
}

PodLister gets the pods running in the cluster