controller

Documentation

Index

• type Collector
  • func NewCollector(config *conf.Collector) *Collector
  • func (c *Collector) CrawlMetadata(ctx context.Context, req *wrapperspb.StringValue) (*pb.CrawlMetadataResponse, error)
  • func (c *Collector) CrawlMetadataAsync(ctx context.Context, req *wrapperspb.StringValue) (*emptypb.Empty, error)
  • func (c *Collector) FetchMetadata(req *wrapperspb.StringValue, resp grpc.ServerStreamingServer[entity.Metadata]) error
  • func (c *Collector) Service() func(*grpc.Server)

Types

type Collector

type Collector struct {
	pb.UnimplementedCollectorServer
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector(config *conf.Collector) *Collector

func (*Collector) CrawlMetadata

func (c *Collector) CrawlMetadata(ctx context.Context, req *wrapperspb.StringValue) (*pb.CrawlMetadataResponse, error)

func (*Collector) CrawlMetadataAsync

func (c *Collector) CrawlMetadataAsync(ctx context.Context, req *wrapperspb.StringValue) (*emptypb.Empty, error)

func (*Collector) FetchMetadata

func (c *Collector) FetchMetadata(req *wrapperspb.StringValue, resp grpc.ServerStreamingServer[entity.Metadata]) error

func (*Collector) Service

func (c *Collector) Service() func(*grpc.Server)