func (s *Service) GetSource(ctx context.Context, in *collectorpb.GetSourceRequest) (*collectorpb.GetSourceResponse, error) {
	result, err := s.getSource(ctx, in.Url, in.Format, in.Parser)
	if err != nil {
		return &collectorpb.GetSourceResponse{}, fmt.Errorf("unable to fetch source %s, error: %v", in.Url, err)
	}
	return &collectorpb.GetSourceResponse{Result: result}, nil
}
// GetSource information about a specific configured Watch
GetSource information about a specific configured Watch
// GetSource information about a specific configured Watch
func (s *Service) GetSource(ctx context.Context, in *collectorpb.GetSourceRequest) (*collectorpb.GetSourceResponse, error) {
	result, err := s.getSource(ctx, in.Url, in.Format, in.Parser)
	if err != nil {
		return &collectorpb.GetSourceResponse{}, fmt.Errorf("unable to fetch source %s, error: %v", in.Url, err)
	}
	return &collectorpb.GetSourceResponse{Result: result}, nil
}
func ( s * Service ) GetSource ( ctx context . Context , in * collectorpb . GetSourceRequest ) ( * collectorpb . GetSourceResponse , error ) { result , err := s . getSource ( ctx , in . Url , in . Format , in . Parser ) if err != nil { return & collectorpb . GetSourceResponse { } , fmt . Errorf ( " " , in . Url , err ) } return & collectorpb . GetSourceResponse { Result : result } , nil }
GetSource information about a specific configured Watch
GetSource information about a specific configured Watch